Commit in servicemix/ws/jaxws/wsnotification/src on MAIN
main/java/org/servicemix/ws/notification/impl/ActiveMQSubscriptionManager.java+8-21.1 -> 1.2
test/java/org/servicemix/ws/notification/impl/ActiveMQNotificationBrokerTest.java+4-21.2 -> 1.3
+12-4
2 modified files
fixed test cases

servicemix/ws/jaxws/wsnotification/src/main/java/org/servicemix/ws/notification/impl
ActiveMQSubscriptionManager.java 1.1 -> 1.2
diff -u -r1.1 -r1.2
--- ActiveMQSubscriptionManager.java	24 Aug 2005 14:45:59 -0000	1.1
+++ ActiveMQSubscriptionManager.java	24 Aug 2005 15:25:52 -0000	1.2
@@ -168,8 +168,11 @@
             parameterStyle = SOAPBinding.ParameterStyle.BARE)
     public Object pauseSubscription(
             @WebParam(name = "PauseSubscription", targetNamespace = "http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BaseNotification-1.2-draft-01.xsd")
-            Object pauseSubscriptionRequest) throws PauseFailedFault, ResourceUnknownFault {
+            Object request) throws PauseFailedFault, ResourceUnknownFault {
         /** TODO - should be removed from API */
+        if (request instanceof EndpointReferenceType) {
+            pauseSubcription((EndpointReferenceType) request);
+        }
         return null;
     }
 
@@ -179,8 +182,11 @@
             parameterStyle = SOAPBinding.ParameterStyle.BARE)
     public Object resumeSubscription(
             @WebParam(name = "ResumeSubscription", targetNamespace = "http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BaseNotification-1.2-draft-01.xsd")
-            Object resumeSubscriptionRequest) throws ResourceUnknownFault, ResumeFailedFault {
+            Object request) throws ResourceUnknownFault, ResumeFailedFault {
         /** TODO - should be removed from API */
+        if (request instanceof EndpointReferenceType) {
+            resumeSubscription((EndpointReferenceType) request);
+        }
         return null;
     }
 }

servicemix/ws/jaxws/wsnotification/src/test/java/org/servicemix/ws/notification/impl
ActiveMQNotificationBrokerTest.java 1.2 -> 1.3
diff -u -r1.2 -r1.3
--- ActiveMQNotificationBrokerTest.java	24 Aug 2005 15:07:09 -0000	1.2
+++ ActiveMQNotificationBrokerTest.java	24 Aug 2005 15:25:52 -0000	1.3
@@ -32,7 +32,7 @@
 import java.util.List;
 
 /**
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
  */
 public class ActiveMQNotificationBrokerTest extends TestSupport {
 
@@ -54,7 +54,7 @@
     }
 */
 
-    public void XtestSendNotify() throws Exception {
+    public void testSendNotify() throws Exception {
 
         ActiveMQNotificationBroker broker = new ActiveMQNotificationBroker();
         ActiveMQConnection connection = broker.getConnection();
@@ -75,6 +75,8 @@
 
         Message message = consumer.receive(3000);
         assertNotNull(message);
+
+        System.out.println("Received inbound message: " + message);
     }
 
     public void testSubscribe() throws Exception {
CVSspam 0.2.8



Reply via email to