[jboss-remoting-commits] JBoss Remoting SVN: r3528 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/soak.

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

Author: ron.sigal at jboss.com
Date: 2008-02-27 19:22:03 -0500 (Wed, 27 Feb 2008)
New Revision: 3528

Modified:
   remoting2/branches/2.x/src/tests/org/jboss/test/remoting/soak/ProducerConsumerSoakTestParent.java
Log:
JBREM-911: Added oneway callbacks.

Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/soak/ProducerConsumerSoakTestParent.java
===================================================================
--- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/soak/ProducerConsumerSoakTestParent.java	2008-02-28 00:16:48 UTC (rev 3527)
+++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/soak/ProducerConsumerSoakTestParent.java	2008-02-28 00:22:03 UTC (rev 3528)
@@ -46,6 +46,7 @@
 import org.jboss.remoting.callback.Callback;
 import org.jboss.remoting.callback.HandleCallbackException;
 import org.jboss.remoting.callback.InvokerCallbackHandler;
+import org.jboss.remoting.callback.ServerInvokerCallbackHandler;
 import org.jboss.remoting.transport.Connector;
 import org.jboss.remoting.transport.PortUtil;
 import org.jboss.remoting.transport.bisocket.Bisocket;
@@ -217,7 +218,8 @@
          Iterator it = listeners.iterator();
          while(it.hasNext())
          {
-            InvokerCallbackHandler handler = (InvokerCallbackHandler) it.next();
+            ServerInvokerCallbackHandler handler = (ServerInvokerCallbackHandler) it.next();
+            handler.handleCallbackOneway(c);
             handler.handleCallback(c);
          }