Package com.sun.enterprise.ee.cms.core

Examples of com.sun.enterprise.ee.cms.core.DistributedStateCache


        }
        return hostAddress;
    }

    private DistributedStateCache getDSC() {
        DistributedStateCache cache = null;
        try {
            GroupManagementService gms =
                    GMSFactory.getGMSModule(ReplicationUtil.getClusterName());
            cache = gms.getGroupHandle().getDistributedStateCache();
        } catch (Exception ex) {
View Full Code Here


    }

    // publish the server socket address in DSC.
    public void publishAddress() {
        try {
            DistributedStateCache cache = getDSC();
            String memberTokenId = ReplicationUtil.getInstanceName();
            cache.addToCache(COMP_NAME, memberTokenId, SOCKET_ADDR, publishAddress);
        } catch (Exception ex) {
            logger.log(Level.SEVERE, ex.getMessage(), ex);
        }
    }
View Full Code Here

        }
    }

    // get the remote socket address from DSC.
    public HashMap getPublishedAddress(String instanceName) {
        DistributedStateCache cache = getDSC();
        String memberTokenId = instanceName;
        try {
            HashMap props = ((HashMap) cache.getFromCache(
                    COMP_NAME, memberTokenId, SOCKET_ADDR));
            return props;
        } catch (Exception ex) {
            return null;
        }
View Full Code Here

        String instance = fence.getInstanceRecoveredFor(logdir, timestamp);
        if (_logger.isLoggable(Level.INFO)) {
            _logger.log(Level.INFO, "[GMSCallBack] Instance " + instance + " need to finish delegated recovering");
        }
        if (instance != null) {
            DistributedStateCache dsc=gms.getGroupHandle().getDistributedStateCache();
            Map<Serializable, Serializable> memberDetails = dsc.getFromCacheForPattern(MEMBER_DETAILS, instance );
            delegatedLogDir = (String)memberDetails.get(TXLOGLOCATION);
            if (_logger.isLoggable(Level.INFO)) {
                _logger.log(Level.INFO, "[GMSCallBack] Tx log dir for instance " + instance + " is " + delegatedLogDir);
            }
View Full Code Here

        String instance = fence.getInstanceRecoveredFor(logdir, timestamp);
        if (_logger.isLoggable(Level.INFO)) {
            _logger.log(Level.INFO, "[GMSCallBack] Instance " + instance + " need to finish delegated recovering");
        }
        if (instance != null) {
            DistributedStateCache dsc=gms.getGroupHandle().getDistributedStateCache();
            Map<Serializable, Serializable> memberDetails = dsc.getFromCacheForPattern(MEMBER_DETAILS, instance );
            delegatedLogDir = (String)memberDetails.get(TXLOGLOCATION);
            if (_logger.isLoggable(Level.INFO)) {
                _logger.log(Level.INFO, "[GMSCallBack] Tx log dir for instance " + instance + " is " + delegatedLogDir);
            }
View Full Code Here

        String instance = fence.getInstanceRecoveredFor(logdir, timestamp);
        if (_logger.isLoggable(Level.INFO)) {
            _logger.log(Level.INFO, "[GMSCallBack] Instance " + instance + " need to finish delegated recovering");
        }
        if (instance != null) {
            DistributedStateCache dsc=gms.getGroupHandle().getDistributedStateCache();
            Map<Serializable, Serializable> memberDetails = dsc.getFromCacheForPattern(MEMBER_DETAILS, instance );
            delegatedLogDir = (String)memberDetails.get(TXLOGLOCATION);
            if (_logger.isLoggable(Level.INFO)) {
                _logger.log(Level.INFO, "[GMSCallBack] Tx log dir for instance " + instance + " is " + delegatedLogDir);
            }
View Full Code Here

TOP

Related Classes of com.sun.enterprise.ee.cms.core.DistributedStateCache

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.