Examples of org.apache.axis2.clustering.ClusteringAgent.sendMessage()

Class org.apache.axis2.clustering.ClusteringAgent

Examples of org.apache.axis2.clustering.ClusteringAgent.sendMessage()

org.apache.axis2.clustering.ClusteringAgent.sendMessage()
Send a message to all members in this member's primary cluster @param msg The message to be sent @param isRpcMessage Indicates whether the message has to be sent in RPC mode @return A list of responses if the message is sent in RPC mode @throws ClusteringFault If an error occurs while sending the message

        ClusteringAgent clusteringAgent = AutoscalerTaskDSHolder.getInstance().getAgent();
        if (clusteringAgent != null) {
            RequestTokenReplicationCommand msg = new RequestTokenReplicationCommand();
            msg.setAppDomainContexts(appDomainContexts);
            try {
                clusteringAgent.sendMessage(msg, true);
                System.setProperty(AutoscaleConstants.IS_TOUCHED, "false");
                log.debug("Request token replication messages sent out successfully!!");


            } catch (ClusteringFault e) {
                log.error("Failed to send the request token replication message.", e);

View Full Code Here


    public static List<TenantDataBean> getActiveTenantsInCluster() throws AxisFault {
        List<TenantDataBean> tenants = new ArrayList<TenantDataBean>();
        try {
            ClusteringAgent agent = getClusteringAgent();
            List<ClusteringCommand> list = agent.sendMessage(new GetActiveTenantsInMemberRequest(), true);
            if (log.isDebugEnabled()) {
                log.debug("sent cluster command to to get Active tenants on cluster");
            }
            for (ClusteringCommand command : list) {
                if (command instanceof GetActiveTenantsInMemberResponse) {

View Full Code Here

                    AxisMessage message = new AxisMessage();
                    message.setMessageType(SOAP11Constants.SOAP_11_CONTENT_TYPE);
                    SOAPFactory factory = OMAbstractFactory.getSOAP11Factory();
                    SOAPEnvelope envelope = factory.getDefaultEnvelope();
                    message.setEnvelope(envelope);
                    client.sendMessage(options, new ContentType(message.getMessageType()), message);
                }
                if (preloadMessages) {
                    endpointResourceSet.setUp();
                    endpointResourceSets[i] = endpointResourceSet;
                }

View Full Code Here

TOP

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.