| Commit in servicemix/ws/jaxws/wsnotification/src on MAIN | |||
| main/java/org/servicemix/ws/notification/impl/ActiveMQSubscriptionManager.java | +8 | -2 | 1.1 -> 1.2 |
| test/java/org/servicemix/ws/notification/impl/ActiveMQNotificationBrokerTest.java | +4 | -2 | 1.2 -> 1.3 |
| +12 | -4 | ||
fixed test cases
servicemix/ws/jaxws/wsnotification/src/main/java/org/servicemix/ws/notification/impl
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
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 {
