* Copyright 2004,2005 The Apache Software Foundation.

*

* Licensed under the Apache License, Version 2.0 (the "License"); you may not

* use this file except in compliance with the License. You may obtain a copy of

* the License at

*

* http://www.apache.org/licenses/LICENSE-2.0

*

* Unless required by applicable law or agreed to in writing, software

* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT

* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the

* License for the specific language governing permissions and limitations under

* the License.

*/

  private final static String applicationNamespaceName = "http://tempuri.org/";

  private final static String echoString = "echoString";

  private final static String Text = "Text";

  private final static String Sequence = "Sequence";

  private final static String echoStringResponse = "echoStringResponse";

  private final static String EchoStringReturn = "EchoStringReturn";

 

  private String toIP = "127.0.0.1";

 

  private String toPort = "8070";

 

  private String toEPR = "http://" + toIP +  ":" + toPort + "/axis2/services/RMSampleService";

  private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change this to ur path.

 

  private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + File.separator + "target" + File.separator +"repos" + File.separator + "client" + File.separator;   //this will be available after a maven build

 

  public static void main(String[] args) throws Exception {

   

    String axisClientRepo = null;

    if (args!=null && args.length>0)

      axisClientRepo = args[0];

   

    if (axisClientRepo!=null && !"".equals(axisClientRepo)) {

      AXIS2_CLIENT_PATH = axisClientRepo;

      SANDESHA2_HOME = "";

    }

   

    new SyncEchoClient().run();

  }

 

  private void run () throws Exception {

    if ("<SANDESHA2_HOME>".equals(SANDESHA2_HOME)){

      System.out.println("ERROR: Please change <SANDESHA2_HOME> to your Sandesha2 installation directory.");

      return;

    }

   

    String axis2_xml = AXIS2_CLIENT_PATH + "client_axis2.xml";

    ConfigurationContext configContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH,axis2_xml);

    ServiceClient serviceClient = new ServiceClient (configContext,null);

   

   

    Options clientOptions = new Options ();

   

    clientOptions.setTo(new EndpointReference (toEPR));

   

    String sequenceKey = "sequence3";

    clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);

    //You must set the following two properties in the request-reply case.

    clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);

    clientOptions.setUseSeparateListener(true);

    clientOptions.setAction("urn:wsrm:EchoString");

   

//    clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);   //uncomment this to send messages in SOAP 1.2

//    clientOptions.setProperty(SandeshaClient.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.v1_1);  //uncomment this to send the messages according to the v1_1 spec.

//    clientOptions.setProperty(SandeshaClient.OFFERED_SEQUENCE_ID,SandeshaUtil.getUUID());  //Uncomment this to offer a sequenceID for the incoming sequence.

   

    serviceClient.setOptions(clientOptions);

   

    Callback callback1 = new TestCallback ("Callback 1");

    serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo1",sequenceKey),callback1);

   

    clientOptions.setAction("urn:wsrm:EchoString");

    Callback callback2 = new TestCallback ("Callback 2");

    serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo2",sequenceKey),callback2);

   

    clientOptions.setAction("urn:wsrm:EchoString");

   

    clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");

    Callback callback3 = new TestCallback ("Callback 3");

    serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo3",sequenceKey),callback3);

   

        while (!callback3.isComplete()) {

            Thread.sleep(1000);

        }

  }

  private static OMElement getEchoOMBlock(String text, String sequenceKey) {   

    OMFactory fac = OMAbstractFactory.getOMFactory();

    OMNamespace applicationNamespace = fac.createOMNamespace(applicationNamespaceName,"ns1");

    OMElement echoStringElement = fac.createOMElement(echoString, applicationNamespace);

    OMElement textElem = fac.createOMElement(Text,applicationNamespace);

    OMElement sequenceElem = fac.createOMElement(Sequence,applicationNamespace);

   

    textElem.setText(text);

    sequenceElem.setText(sequenceKey);

    echoStringElement.addChild(textElem);

    echoStringElement.addChild(sequenceElem);

    return echoStringElement;

  }

    String name = null;

   

    public TestCallback (String name) {

      this.name = name;

    }

   

    public String toString () {

      return name;

    }

   

    public void onComplete(AsyncResult result) {

      //System.out.println("On Complete Called for " + text);

      SOAPBody body = result.getResponseEnvelope().getBody();

     

      OMElement echoStringResponseElem = body.getFirstChildWithName(new QName (applicationNamespaceName,echoStringResponse));

      if (echoStringResponseElem==null) {

        System.out.println("Error: SOAPBody does not have a 'echoStringResponse' child");

        return;

      }

     

      OMElement echoStringReturnElem = echoStringResponseElem.getFirstChildWithName(new QName (applicationNamespaceName,EchoStringReturn));

      if (echoStringReturnElem==null) {

        System.out.println("Error: 'echoStringResponse' element does not have a 'EchoStringReturn' child");

        return;

      }

     

      String resultStr = echoStringReturnElem.getText();

      System.out.println("Callback '" + name +  "' got result:" + resultStr);

     

    }

    public void onError(Exception e) {

      // TODO Auto-generated method stub

      System.out.println("Error reported for test call back");

    }

  }

 

}