Package org.apache.axis2.clustering.management

Examples of org.apache.axis2.clustering.management.GroupManagementAgent.send()

61
62
63
64
65
66
67
68
69
70
71
    clientOptions.setSoapAction("urn:wsrm:Ping");
    clientOptions.setAction("urn:wsrm:Ping");
      sender.send("ping",getPingOMBlock("Microsoft-1"));
    sender.send("ping",getPingOMBlock("Microsoft-2"));
    clientOptions.setProperty(ClientAPI.LAST_MESSAGE, "true");
    sender.send("ping",getPingOMBlock("Microsoft-3"));
  }
 
  private static OMElement getPingOMBlock(String text) {
    OMFactory fac = OMAbstractFactory.getOMFactory();
    OMNamespace ns = fac.createOMNamespace("http://tempuri.org/",
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
    clientOptions.setTo(new EndpointReference(toEPR));
    clientOptions.setProperty(Sandesha2ClientAPI.SEQUENCE_KEY,"sequence1");
    sender.send("ping",getPingOMBlock("ping1"));
    sender.send("ping",getPingOMBlock("ping2"));
    clientOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true");
    sender.send("ping",getPingOMBlock("ping3"));

  }
 
  private static OMElement getPingOMBlock(String text) {
    OMFactory fac = OMAbstractFactory.getOMFactory();
View Full Code Here
37
38
39
40
41
42
43
44
45
46
47
            MessageSender msgSender = new MessageSender();
            msgSender.setTo(targetEPR);
            msgSender.setSenderTransport(Constants.TRANSPORT_HTTP);

            msgSender.send("ping", payload);

        } catch (AxisFault axisFault) {
            axisFault.printStackTrace();
        }
    }
View Full Code Here
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(toEpr));
        msgSender.setSenderTransport(Constants.TRANSPORT_MAIL);
        msgSender.send("echo", getPayload());
    }

    private static OMElement getPayload() {
        OMFactory fac = OMAbstractFactory.getOMFactory();
        OMNamespace omNs = fac.createOMNamespace(
View Full Code Here
23
24
25
26
27
28
29
30
31
32
33
            MessageSender msgSender = new MessageSender();
            msgSender.setTo(targetEPR);
            msgSender.setSenderTransport(Constants.TRANSPORT_HTTP);

            msgSender.send("ping", payload);

        } catch (AxisFault axisFault) {
            axisFault.printStackTrace();
        }
    }
View Full Code Here
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
34
35
36
37
38
39
40
41
42
43
44
            MessageSender msgSender = new MessageSender();
            msgSender.setTo(targetEPR);
            msgSender.setSenderTransport(Constants.TRANSPORT_HTTP);

            msgSender.send("ping", payload);

        } catch (AxisFault axisFault) {
            axisFault.printStackTrace();
        }
    }
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
    public static void main(String[] args) throws AxisFault {
        MessageSender msgSender = new MessageSender();
        msgSender.setTo(
                new EndpointReference(toEpr));
        msgSender.setSenderTransport(Constants.TRANSPORT_MAIL);
        msgSender.send("echo", getPayload());
    }

    private static OMElement getPayload() {
        OMFactory fac = OMAbstractFactory.getOMFactory();
        OMNamespace omNs = fac.createOMNamespace(
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
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.