svn commit: r941668 - /synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/eventing/SynapseEventSourceTest.java

[hi...@apache.org]

Author: hiranya
Date: Thu May  6 11:28:54 2010
New Revision: 941668

URL: http://svn.apache.org/viewvc?rev=941668&view=rev
Log:
Updated event source test


Modified:
    synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/eventing/SynapseEventSourceTest.java

Modified: synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/eventing/SynapseEventSourceTest.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/eventing/SynapseEventSourceTest.java?rev=941668&r1=941667&r2=941668&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/eventing/SynapseEventSourceTest.java (original)
+++ synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/eventing/SynapseEventSourceTest.java Thu May  6 11:28:54 2010
@@ -59,6 +59,7 @@ public class SynapseEventSourceTest exte
     public void testSubscriptionHandling() {
         subscribeTest();
         renewTest();
+        unsubscribeTest();
     }
 
     private void subscribeTest() {
@@ -144,6 +145,28 @@ public class SynapseEventSourceTest exte
 
     }
 
+    public void unsubscribeTest() {
+        String message =
+                "<wse:Unsubscribe xmlns:wse=\"http://schemas.xmlsoap.org/ws/2004/08/eventing\"/>";
+
+        try {
+            MessageContext msgCtx = createMessageContext(message, EventingConstants.WSE_UNSUBSCRIBE);
+            QName qname = new QName(EventingConstants.WSE_EVENTING_NS,
+                    EventingConstants.WSE_EN_IDENTIFIER, "wse");
+            TestUtils.addSOAPHeaderBlock(msgCtx, qname, id);
+            source.receive(msgCtx);
+        } catch (Exception ignored) {
+
+        }
+
+        try {
+            assertEquals(0, subMan.getSubscriptions().size());
+        } catch (EventException e) {
+            fail("Eventing exception occured while accessing the subscription manager");
+        }
+
+    }
+
     private MessageContext createMessageContext(String payload, String action) {
         try {
             SynapseConfiguration synapseConfig = new SynapseConfiguration();