Examples of DistributedStateCache

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

144
145
146
147
148
149
150
151
152
153
154
        }
        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

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

158
159
160
161
162
163
164
165
166
167
168
169
    }

    // 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

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

168
169
170
171
172
173
174
175
176
177
178
179
180
181
        }
    }

    // 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

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

197
198
199
200
201
202
203
204
205
206
207
208
        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

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

196
197
198
199
200
201
202
203
204
205
206
207
        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

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

190
191
192
193
194
195
196
197
198
199
200
201
        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
Copyright © 2018 www.massapi.com. 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.