Author: asankaa Date: Wed Dec 17 03:30:58 2008 New Revision: 27111 URL: http://wso2.org/svn/browse/wso2?view=rev&revision=27111
Log: change the eventsender to send one way messages Modified: branches/synapse/1.2.wso2v1/modules/samples/src/main/java/samples/userguide/EventSender.java Modified: branches/synapse/1.2.wso2v1/modules/samples/src/main/java/samples/userguide/EventSender.java URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.2.wso2v1/modules/samples/src/main/java/samples/userguide/EventSender.java?rev=27111&r1=27110&r2=27111&view=diff ============================================================================== --- branches/synapse/1.2.wso2v1/modules/samples/src/main/java/samples/userguide/EventSender.java (original) +++ branches/synapse/1.2.wso2v1/modules/samples/src/main/java/samples/userguide/EventSender.java Wed Dec 17 03:30:58 2008 @@ -29,6 +29,7 @@ import org.apache.axis2.client.ServiceClient; import org.apache.axis2.context.ConfigurationContext; import org.apache.axis2.context.ConfigurationContextFactory; +import org.apache.axis2.context.MessageContext; import java.io.File; @@ -89,6 +90,7 @@ serviceClient.engageModule("addressing"); options.setTo(new EndpointReference(addUrl)); options.setAction(action); + options.setProperty(MessageContext.TRANSPORT_NON_BLOCKING, Boolean.FALSE); // set for fire and foget serviceClient.setOptions(options); serviceClient.addHeader(topicOm); OMElement payload = AXIOMUtil.stringToOM("<m:placeOrder xmlns:m=\"http://services.samples/xsd\";>\n" + @@ -101,8 +103,9 @@ System.out.println("Sending Event : \n" + payload.toString()); try { - serviceClient.sendRobust(payload); + serviceClient.fireAndForget(payload); System.out.println("Event sent to topic " + topic); + Thread.sleep(1000); if (configContext != null) { configContext.terminate(); } _______________________________________________ Esb-java-dev mailing list [email protected] https://wso2.org/cgi-bin/mailman/listinfo/esb-java-dev
