Examples of GetStateResponseCommand

Examples of org.apache.axis2.clustering.control.GetStateResponseCommand

51
52
53
54
55
56
57
58
59
60
61
62
            if (configurationContext.
                    getPropertyNonReplicable(ClusteringConstants.CLUSTER_INITIALIZED) == null) {
                return null;
            }
            command.execute(configurationContext);
            GetStateResponseCommand getStateRespCmd = new GetStateResponseCommand();
            getStateRespCmd.setCommands(((GetStateCommand) command).getCommands());
            return getStateRespCmd;
        } else if (command instanceof GetConfigurationCommand) {

            // If a GetConfigurationCommand is received by a node which has not yet initialized
            // this node cannot send a response to the state requester. So we simply return.
View Full Code Here

Examples of org.apache.axis2.clustering.control.GetStateResponseCommand

58
59
60
61
62
63
64
65
66
67
68
69
            if (configurationContext.
                    getPropertyNonReplicable(ClusteringConstants.CLUSTER_INITIALIZED) == null) {
                return;
            }
            command.execute(configurationContext);
            GetStateResponseCommand getStateRespCmd = new GetStateResponseCommand();
            getStateRespCmd.setCommands(((GetStateCommand) command).getCommands());
            channelSender.sendToMember(getStateRespCmd, sender);
        } else if (command instanceof GetConfigurationCommand) {

            // If a GetConfigurationCommand is received by a node which has not yet initialized
            // this node cannot send a response to the state requester. So we simply return.
View Full Code Here

Examples of org.apache.axis2.clustering.control.GetStateResponseCommand

64
65
66
67
68
69
70
71
72
73
74
75
            try {
                log.info("Received " + msg + " initialization request message from " +
                         TribesUtil.getName(invoker));
                GetStateCommand command = (GetStateCommand) msg;
                command.execute(configurationContext);
                GetStateResponseCommand getStateRespCmd = new GetStateResponseCommand();
                getStateRespCmd.setCommands(command.getCommands());
                return getStateRespCmd;
            } catch (ClusteringFault e) {
                String errMsg = "Cannot handle initialization request";
                log.error(errMsg, e);
                throw new RemoteProcessException(errMsg, e);
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.