Package org.apache.axis2.client

Examples of org.apache.axis2.client.ServiceClient.fireAndForget()

169
170
171
172
173
174
175
176
177
178
179
   
    String sequenceKey2 = "sequence4";
    clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey2);
   
    clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "false");
    serviceClient.fireAndForget(getPingOMBlock("ping1"));   
   
    long limit = System.currentTimeMillis() + waitTime;
    Error lastError = null;
    while(System.currentTimeMillis() < limit) {
      Thread.sleep(tickTime); // Try the assertions each tick interval, until they pass or we time out
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
    ServiceClient serviceClient = new ServiceClient (configContext,null);
    //serviceClient.

    serviceClient.setOptions(clientOptions);
   
    serviceClient.fireAndForget(getTestOperationOMBlock("ping1"));
   
    clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
    serviceClient.fireAndForget(getTestOperationOMBlock("ping2"));
   
    long limit = System.currentTimeMillis() + waitTime;
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
    serviceClient.setOptions(clientOptions);
   
    serviceClient.fireAndForget(getTestOperationOMBlock("ping1"));
   
    clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
    serviceClient.fireAndForget(getTestOperationOMBlock("ping2"));
   
    long limit = System.currentTimeMillis() + waitTime;
    Error lastError = null;
    while(System.currentTimeMillis() < limit) {
      Thread.sleep(tickTime); // Try the assertions each tick interval, until they pass or we time out
View Full Code Here
1093
1094
1095
1096
1097
1098
1099
1100
1101
1102
1103
      //If it's oneway or async, reallocate
      EndpointReference replyTo = oldRMSBean.getReplyToEndpointReference();
      int mep = axisOperation.getAxisSpecificMEPConstant();
      if(mep == WSDLConstants.MEP_CONSTANT_OUT_ONLY){
        client.fireAndForget(msgCtx.getEnvelope().getBody().cloneOMElement().getFirstElement());
      } else if (replyTo == null || replyTo.hasAnonymousAddress()){
        //It is sync2way and therefore we should fail
        transaction = storageManager.getTransaction();

        RMSBeanMgr mgr = storageManager.getRMSBeanMgr();
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
    //serviceClient.
   
    serviceClient.setOptions(clientOptions);
   
    clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
    serviceClient.fireAndForget(getPingOMBlock("ping3"));

    Thread.sleep(10000);
       
    SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
    assertTrue(sequenceReport.getCompletedMessages().contains(new Long(1)));
View Full Code Here
143
144
145
146
147
148
149
150
151
152
153
    //serviceClient.
   
    serviceClient.setOptions(clientOptions);
   
    clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
    serviceClient.fireAndForget(getPingOMBlock("ping3"));

    Thread.sleep(10000);
       
    SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
    assertTrue(sequenceReport.getCompletedMessages().contains(new Long(1)));
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
    //serviceClient.
   
    serviceClient.setOptions(clientOptions);
   
    clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
    serviceClient.fireAndForget(getPingOMBlock("ping3"));

    Thread.sleep(15000);
       
    SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
    assertTrue(sequenceReport.getCompletedMessages().contains(new Long(1)));
View Full Code Here
143
144
145
146
147
148
149
150
151
152
153
    //serviceClient.
   
    serviceClient.setOptions(clientOptions);
   
    clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
    serviceClient.fireAndForget(getPingOMBlock("ping3"));

    Thread.sleep(15000);
       
    SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
    assertTrue(sequenceReport.getCompletedMessages().contains(new Long(1)));
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
    //serviceClient.
   
    serviceClient.setOptions(clientOptions);
   
    clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
    serviceClient.fireAndForget(getPingOMBlock("ping3"));

    Thread.sleep(10000);
       
    SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
    assertTrue(sequenceReport.getCompletedMessages().contains(new Long(1)));
View Full Code Here
140
141
142
143
144
145
146
147
148
149
150
    //serviceClient.
   
    serviceClient.setOptions(clientOptions);
   
    clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
    serviceClient.fireAndForget(getPingOMBlock("ping3"));

    Thread.sleep(10000);
       
    SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
    assertTrue(sequenceReport.getCompletedMessages().contains(new Long(1)));
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.