[jboss-cvs] JBoss Messaging SVN: r2039 - trunk/tests/src/org/jboss/test/messaging/jms.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2007-01-24 14:38:34 -0500 (Wed, 24 Jan 2007)
New Revision: 2039

Modified:
   trunk/tests/src/org/jboss/test/messaging/jms/WireFormatTest.java
Log:
http://jira.jboss.org/jira/browse/JBMESSAGING-778 and http://jira.jboss.org/jira/browse/JBMESSAGING-773

Modified: trunk/tests/src/org/jboss/test/messaging/jms/WireFormatTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/WireFormatTest.java	2007-01-24 19:06:11 UTC (rev 2038)
+++ trunk/tests/src/org/jboss/test/messaging/jms/WireFormatTest.java	2007-01-24 19:38:34 UTC (rev 2039)
@@ -61,6 +61,7 @@
 import org.jboss.remoting.InvokerLocator;
 import org.jboss.remoting.callback.Callback;
 import org.jboss.remoting.invocation.InternalInvocation;
+import org.jboss.remoting.invocation.OnewayInvocation;
 import org.jboss.test.messaging.MessagingTestCase;
 import org.jboss.test.messaging.jms.message.MessageTest;
 import org.jboss.util.id.GUID;
@@ -1312,8 +1313,10 @@
          InputStream ois = new DataInputStream(bis);
          
          InvocationRequest ir2 = (InvocationRequest)wf.read(ois, null);
+
+         OnewayInvocation oneWay = (OnewayInvocation)ir2.getParameter();
          
-         mm = (MessagingMarshallable)ir2.getParameter();
+         mm = (MessagingMarshallable)oneWay.getParameters()[0];
          
          assertEquals(77, mm.getVersion());
          
@@ -1403,9 +1406,11 @@
          InputStream ois = new DataInputStream(bis);
          
          InvocationRequest ir2 = (InvocationRequest)wf.read(ois, null);
+
+         OnewayInvocation oneway = (OnewayInvocation) ir2.getParameter();
+
+         InternalInvocation ii = (InternalInvocation) oneway.getParameters()[0];
          
-         InternalInvocation ii = (InternalInvocation) ir2.getParameter();
-         
          Object[] parameters = ii.getParameters();
          
          assertNotNull(parameters);