[jbossws-commits] JBossWS SVN: r4485 - stack/native/branches/ropalka/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway.
Author: richard.opalka(a)jboss.com
Date: 2007-08-23 08:39:41 -0400 (Thu, 23 Aug 2007)
New Revision: 4485
Modified:
stack/native/branches/ropalka/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway/OneWayTestCase.java
Log:
rewriting test to use dummy WS-RM stuff
Modified:
stack/native/branches/ropalka/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway/OneWayTestCase.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway/OneWayTestCase.java 2007-08-23
12:39:32 UTC (rev 4484)
+++
stack/native/branches/ropalka/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway/OneWayTestCase.java 2007-08-23
12:39:41 UTC (rev 4485)
@@ -22,12 +22,15 @@
package org.jboss.test.ws.jaxws.wsrm.oneway;
import java.net.URL;
+import java.util.concurrent.TimeUnit;
import javax.xml.namespace.QName;
import javax.xml.ws.Service;
import junit.framework.Test;
+import org.jboss.ws.extensions.wsrm.RMSequence;
+import org.jboss.ws.extensions.wsrm.RMSequenceFactory;
import org.jboss.wsf.test.JBossWSTest;
import org.jboss.wsf.test.JBossWSTestSetup;
import org.jboss.test.ws.jaxws.wsrm.OneWayServiceIface;
@@ -52,19 +55,25 @@
protected void setUp() throws Exception
{
super.setUp();
-
QName serviceName = new QName(targetNS, "OneWayService");
URL wsdlURL = new URL("http://" + getServerHost() +
":8080/jaxws-wsrm/OneWayService?wsdl");
-
Service service = Service.create(wsdlURL, serviceName);
proxy = (OneWayServiceIface)service.getPort(OneWayServiceIface.class);
}
- public void testReliableOneWayInvocations() throws Exception
+ public void testOneWayMethods() throws Exception
{
System.out.println("FIXME [JBWS-515] Provide an initial implementation for
WS-ReliableMessaging");
+ RMSequence sequence = RMSequenceFactory.newInstance(proxy);
+ System.out.println("Created sequence with id=" + sequence.getId());
proxy.method1();
proxy.method2("Hello World");
+ sequence.setLastMessage();
proxy.method3(new String[] {"Hello","World"});
+ if (!sequence.completed(1000, TimeUnit.MILLISECONDS)) {
+ fail("Sequence not completed within specified time amount");
+ } else {
+ sequence.terminate();
+ }
}
}