You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by as...@apache.org on 2009/01/16 11:59:41 UTC
svn commit: r734969 [2/2] - in /synapse/trunk/java/modules:
core/src/main/java/org/apache/synapse/config/xml/eventing/
core/src/main/java/org/apache/synapse/eventing/
core/src/main/java/org/apache/synapse/eventing/builders/
core/src/main/java/org/apach...
Modified: synapse/trunk/java/modules/samples/src/main/java/samples/userguide/EventSubscriber.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/EventSubscriber.java?rev=734969&r1=734968&r2=734969&view=diff
==============================================================================
--- synapse/trunk/java/modules/samples/src/main/java/samples/userguide/EventSubscriber.java (original)
+++ synapse/trunk/java/modules/samples/src/main/java/samples/userguide/EventSubscriber.java Fri Jan 16 02:59:35 2009
@@ -23,15 +23,15 @@
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMFactory;
import org.apache.axiom.om.OMNamespace;
+import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.client.ServiceClient;
import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.context.ConfigurationContextFactory;
-import org.apache.axis2.AxisFault;
-import java.io.File;
import javax.xml.namespace.QName;
+import java.io.File;
public class EventSubscriber {
@@ -62,7 +62,8 @@
String prxUrl = getProperty("prxurl", null);
String repo = getProperty("repository", "client_repo");
String topic = getProperty("topic", "synapse/event/test");
- String address = getProperty("address", "http://localhost:9000/services/SimpleStockQuoteService");
+ String address =
+ getProperty("address", "http://localhost:9000/services/SimpleStockQuoteService");
String mode = getProperty("mode", "subscribe");
String identifier = getProperty("identifier", "90000");
String expires = getProperty("expires", "*"); //Format: 2020-12-31T21:07:00.000-08:00
@@ -79,22 +80,28 @@
OMFactory factory = OMAbstractFactory.getOMFactory();
OMElement message = factory.createOMElement("message", null);
- OMNamespace nsxmlins = factory.createOMNamespace("http://www.w3.org/2001/XMLSchema", "xmlns");
- OMNamespace nss11 = factory.createOMNamespace("http://schemas.xmlsoap.org/soap/envelope", "s11");
- OMNamespace nswsa = factory.createOMNamespace("http://schemas.xmlsoap.org/ws/2004/08/addressing", "wsa");
- OMNamespace nswse = factory.createOMNamespace("http://schemas.xmlsoap.org/ws/2004/08/eventing", "wse");
+ OMNamespace nsxmlins =
+ factory.createOMNamespace("http://www.w3.org/2001/XMLSchema", "xmlns");
+ OMNamespace nss11 =
+ factory.createOMNamespace("http://schemas.xmlsoap.org/soap/envelope", "s11");
+ OMNamespace nswsa = factory.createOMNamespace(
+ "http://schemas.xmlsoap.org/ws/2004/08/addressing", "wsa");
+ OMNamespace nswse =
+ factory.createOMNamespace("http://schemas.xmlsoap.org/ws/2004/08/eventing", "wse");
if (mode.equals("subscribe")) {
OMElement subscribeOm = factory.createOMElement("Subscribe", nswse);
OMElement deliveryOm = factory.createOMElement("Delivery", nswse);
- deliveryOm.addAttribute(factory.createOMAttribute("Mode", null, "http://schemas.xmlsoap.org/ws/2004/08/eventing/DeliveryModes/Push"));
+ deliveryOm.addAttribute(factory.createOMAttribute("Mode", null,
+ "http://schemas.xmlsoap.org/ws/2004/08/eventing/DeliveryModes/Push"));
OMElement notifyToOm = factory.createOMElement("NotifyTo", nswse);
OMElement addressOm = factory.createOMElement("Address", nswsa);
factory.createOMText(addressOm, address);
OMElement expiresOm = factory.createOMElement("Expires", nswse);
factory.createOMText(expiresOm, expires);
OMElement filterOm = factory.createOMElement("Filter", nswse);
- filterOm.addAttribute(factory.createOMAttribute("Dialect", null, "http://synapse.apache.org/eventing/dialect/topicFilter"));
+ filterOm.addAttribute(factory.createOMAttribute("Dialect", null,
+ "http://synapse.apache.org/eventing/dialect/topicFilter"));
factory.createOMText(filterOm, topic);
@@ -117,16 +124,19 @@
try {
OMElement response = serviceClient.sendReceive(subscribeOm);
System.out.println("Subscribed to topic " + topic);
- Thread.sleep(1000);
+ Thread.sleep(1000);
System.out.println("Response Received: " + response.toString());
String subId =
- response.getFirstChildWithName(new QName(nswse.getNamespaceURI(), "SubscriptionManager"))
- .getFirstChildWithName(new QName(nswsa.getNamespaceURI(), "ReferenceParameters"))
- .getFirstChildWithName(new QName(nswse.getNamespaceURI(), "Identifier")).getText();
+ response.getFirstChildWithName(
+ new QName(nswse.getNamespaceURI(), "SubscriptionManager"))
+ .getFirstChildWithName(
+ new QName(nswsa.getNamespaceURI(), "ReferenceParameters"))
+ .getFirstChildWithName(
+ new QName(nswse.getNamespaceURI(), "Identifier")).getText();
System.out.println("Subscription identifier: " + subId);
} catch (AxisFault e) {
- System.out.println("Fault Received : "+e.toString());
- System.out.println("Fault Code : "+e.getFaultCode().toString());
+ System.out.println("Fault Received : " + e.toString());
+ System.out.println("Fault Code : " + e.getFaultCode().toString());
}
} else if (mode.equals("unsubscribe")) {
/** Send unsubscribe message
@@ -171,8 +181,8 @@
Thread.sleep(1000);
System.out.println("UnSubscribe Response Received: " + response.toString());
} catch (AxisFault e) {
- System.out.println("Fault Received : "+e.toString());
- System.out.println("Fault Code : "+e.getFaultCode().toString());
+ System.out.println("Fault Received : " + e.toString());
+ System.out.println("Fault Code : " + e.getFaultCode().toString());
}
} else if (mode.equals("renew")) {
@@ -222,10 +232,11 @@
OMElement response = serviceClient.sendReceive(subscribeOm);
System.out.println("SynapseSubscription Renew to ID " + identifier);
Thread.sleep(1000);
- System.out.println("SynapseSubscription Renew Response Received: " + response.toString());
+ System.out.println(
+ "SynapseSubscription Renew Response Received: " + response.toString());
} catch (AxisFault e) {
- System.out.println("Fault Received : "+e.toString());
- System.out.println("Fault Code : "+e.getFaultCode().toString());
+ System.out.println("Fault Received : " + e.toString());
+ System.out.println("Fault Code : " + e.getFaultCode().toString());
}
} else if (mode.equals("getstatus")) {
@@ -272,9 +283,9 @@
Thread.sleep(1000);
System.out.println("GetStatus Response Received: " + response.toString());
} catch (AxisFault e) {
- System.out.println("Fault Received : "+e.toString());
- System.out.println("Fault Code : "+e.getFaultCode().toString());
- }
+ System.out.println("Fault Received : " + e.toString());
+ System.out.println("Fault Code : " + e.getFaultCode().toString());
+ }
}
try {