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

Class org.apache.axis2.client.ServiceClient

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

org.apache.axis2.client.ServiceClient.fireAndForget()
Directly invoke an anonymous operation with an In-Only MEP. This method just sends your supplied XML without the possibility of any response from the service (even an error - though you can still get client-side errors such as "Host not found"). For more control, you can instead create a client for the operation and use that client to execute the send. @param elem XML to send @throws AxisFault ff something goes wrong trying to send the XML @see #createClient(QName)

    ServiceClient serviceClient = new ServiceClient (configContext,null);    


    serviceClient.setOptions(clientOptions);
    
    clientOptions.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(1));
    serviceClient.fireAndForget(getPingOMBlock("ping1"));
    
    clientOptions.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(3));
    serviceClient.fireAndForget(getPingOMBlock("ping3"));
    
    boolean complete = false;

View Full Code Here

    
    clientOptions.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(1));
    serviceClient.fireAndForget(getPingOMBlock("ping1"));
    
    clientOptions.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(3));
    serviceClient.fireAndForget(getPingOMBlock("ping3"));
    
    boolean complete = false;
    while (!complete) {
      SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
      if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==2)

View Full Code Here

    }


    SandeshaClient.closeSequence(serviceClient);
    
    clientOptions.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(4));
    serviceClient.fireAndForget(getPingOMBlock("ping4"));  


    SandeshaClient.terminateSequence(serviceClient);    
    serviceClient.finalizeInvoke();
  }

View Full Code Here

    //serviceClient.
    
    serviceClient.setOptions(clientOptions);
        
    clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
    serviceClient.fireAndForget(getPingOMBlock("ping2"));
    
    try {
      Thread.sleep(30000);
    } catch (InterruptedException e) {
      e.printStackTrace();

View Full Code Here


            Options options = new Options();
            serviceClient.setOptions(options);
            options.setTo(targetEPR);


            serviceClient.fireAndForget(payload);


        } catch (AxisFault axisFault) {
            axisFault.printStackTrace();
        }
    }

View Full Code Here

    
    ServiceClient serviceClient = new ServiceClient (configContext,null);    
    
    serviceClient.setOptions(clientOptions);
    
    serviceClient.fireAndForget(getPingOMBlock("ping1"));
    serviceClient.fireAndForget(getPingOMBlock("ping2"));
    serviceClient.fireAndForget(getPingOMBlock("ping3"));
    
    SequenceReport sequenceReport = null;    
    boolean complete = false;

View Full Code Here

    ServiceClient serviceClient = new ServiceClient (configContext,null);    
    
    serviceClient.setOptions(clientOptions);
    
    serviceClient.fireAndForget(getPingOMBlock("ping1"));
    serviceClient.fireAndForget(getPingOMBlock("ping2"));
    serviceClient.fireAndForget(getPingOMBlock("ping3"));
    
    SequenceReport sequenceReport = null;    
    boolean complete = false;
    while (!complete) {

View Full Code Here

    
    serviceClient.setOptions(clientOptions);
    
    serviceClient.fireAndForget(getPingOMBlock("ping1"));
    serviceClient.fireAndForget(getPingOMBlock("ping2"));
    serviceClient.fireAndForget(getPingOMBlock("ping3"));
    
    SequenceReport sequenceReport = null;    
    boolean complete = false;
    while (!complete) {
      sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);

View Full Code Here


    ServiceClient serviceClient = new ServiceClient (configContext,null);
    clientOptions.setAction("urn:wsrm:Ping");
    serviceClient.setOptions(clientOptions);
    
    serviceClient.fireAndForget(getPingOMBlock("ping1"));
    serviceClient.fireAndForget(getPingOMBlock("ping2"));
    
    clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
    serviceClient.fireAndForget(getPingOMBlock("ping3"));

View Full Code Here

    ServiceClient serviceClient = new ServiceClient (configContext,null);
    clientOptions.setAction("urn:wsrm:Ping");
    serviceClient.setOptions(clientOptions);
    
    serviceClient.fireAndForget(getPingOMBlock("ping1"));
    serviceClient.fireAndForget(getPingOMBlock("ping2"));
    
    clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
    serviceClient.fireAndForget(getPingOMBlock("ping3"));
    
    serviceClient.finalizeInvoke();

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.