Package org.apache.axis2.client

Examples of org.apache.axis2.client.MessageSender.send()

34
35
36
37
38
39
40
41
42
43
44
    public static void main(String[] args) throws AxisFault {
        MessageSender msgSender = new MessageSender();
        msgSender.setTo(new EndpointReference(AddressingConstants.WSA_TO, toEpr));
        msgSender.setSenderTransport(Constants.TRANSPORT_MAIL);
        msgSender.send("echo", getPayload());
    }

    private static OMElement getPayload() {
        OMFactory fac = OMAbstractFactory.getOMFactory();
        OMNamespace omNs = fac.createOMNamespace("http://example1.org/example1", "example1");
View Full Code Here
168
169
170
171
172
173
174
175
176
177
178
                                         clusteringAgent.getGroupManagementAgent(clusterDomain,
                                                                                 clusterSubdomain);

    try {
      log.info("Sending Request to.. " + clusterDomain + " : " + clusterSubdomain);
      groupMgtAgent.send(request);
     
    } catch (ClusteringFault e) {
      e.printStackTrace();
    }
    
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
        return groups.toArray(new Group[groups.size()]);
    }

    public void shutdownGroup(String groupName) throws Exception {
        GroupManagementAgent groupManagementAgent = getGroupManagementAgent(groupName);
        groupManagementAgent.send(new ShutdownMemberCommand());
    }

    public void restartGroup(String groupName) throws Exception {
        GroupManagementAgent groupManagementAgent = getGroupManagementAgent(groupName);
        groupManagementAgent.send(new RestartMemberCommand());
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
        groupManagementAgent.send(new ShutdownMemberCommand());
    }

    public void restartGroup(String groupName) throws Exception {
        GroupManagementAgent groupManagementAgent = getGroupManagementAgent(groupName);
        groupManagementAgent.send(new RestartMemberCommand());
    }

    public void shutdownGroupGracefully(String groupName) throws Exception {
        GroupManagementAgent groupManagementAgent = getGroupManagementAgent(groupName);
        groupManagementAgent.send(new ShutdownMemberGracefullyCommand());
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
        groupManagementAgent.send(new RestartMemberCommand());
    }

    public void shutdownGroupGracefully(String groupName) throws Exception {
        GroupManagementAgent groupManagementAgent = getGroupManagementAgent(groupName);
        groupManagementAgent.send(new ShutdownMemberGracefullyCommand());
    }

    public void restartGroupGracefully(String groupName) throws Exception {
        GroupManagementAgent groupManagementAgent = getGroupManagementAgent(groupName);
        groupManagementAgent.send(new RestartMemberGracefullyCommand());
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
        groupManagementAgent.send(new ShutdownMemberGracefullyCommand());
    }

    public void restartGroupGracefully(String groupName) throws Exception {
        GroupManagementAgent groupManagementAgent = getGroupManagementAgent(groupName);
        groupManagementAgent.send(new RestartMemberGracefullyCommand());
    }

    public void shutdownCluster() throws Exception {
        sendToCluster(new ShutdownMemberCommand());
    }
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
        sendToCluster(new RestartMemberGracefullyCommand());
    }

    public void startGroupMaintenance(String groupName) throws Exception {
        GroupManagementAgent groupManagementAgent = getGroupManagementAgent(groupName);
        groupManagementAgent.send(new StartMaintenanceCommand());
    }

    public void endGroupMaintenance(String groupName) throws Exception {
        GroupManagementAgent groupManagementAgent = getGroupManagementAgent(groupName);
        groupManagementAgent.send(new EndMaintenanceCommand());
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
        groupManagementAgent.send(new StartMaintenanceCommand());
    }

    public void endGroupMaintenance(String groupName) throws Exception {
        GroupManagementAgent groupManagementAgent = getGroupManagementAgent(groupName);
        groupManagementAgent.send(new EndMaintenanceCommand());
    }

    public void startClusterMaintenance() throws Exception {
        sendToCluster(new StartMaintenanceCommand());
    }
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
        ClusteringAgent clusteringAgent = getClusteringAgent();
        Set<String> groupNames = clusteringAgent.getDomains();
        for (String groupName : groupNames) {
            GroupManagementAgent managementAgent =
                    clusteringAgent.getGroupManagementAgent(groupName);
            managementAgent.send(cmd);
        }
    }

    private GroupManagementAgent getGroupManagementAgent(String groupName) throws AxisFault {
        ClusteringAgent clusteringAgent = getClusteringAgent();
View Full Code Here
229
230
231
232
233
234
235
236
237
238
239
            response = engine.resumeSend(msgCtx);
          } else {
            if (log.isDebugEnabled())
              log.debug("Sending a message : " + msgCtx.getEnvelope().getHeader());
            msgCtx.setProperty(MessageContext.TRANSPORT_NON_BLOCKING, Boolean.FALSE);
            engine.send(msgCtx);  // TODO check if this should return an invocation response
          }
        } else {
          // had to fully build the SOAP envelope to support
          // retransmissions.
          // Otherwise a 'parserAlreadyAccessed' exception could
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.