Author: ron.sigal(a)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);
}
Show replies by date