1
package org.jboss.test.remoting.callback.push.unidirectional;
3
import junit.framework.TestCase;
4
import org.jboss.remoting.Client;
5
import org.jboss.remoting.InvokerLocator;
6
import org.jboss.remoting.callback.Callback;
7
import org.jboss.remoting.callback.HandleCallbackException;
8
import org.jboss.remoting.callback.InvokerCallbackHandler;
10
import java.util.HashMap;
13
* @author <a href="mailto:tom.elrod@jboss.com">Tom Elrod</a>
15
public abstract class CallbackPushTestClient extends TestCase
17
private boolean gotCallback = false;
19
public void testCallback() throws Throwable
21
Client client = new Client(new InvokerLocator(getLocatorUri()));
23
InvokerCallbackHandler testCallbackHandler = new TestCallbackHandler();
24
client.addListener(testCallbackHandler, new HashMap(), null, true);
25
client.invoke("foobar");
29
client.removeListener(testCallbackHandler);
32
assertTrue(gotCallback);
35
private String getLocatorUri()
37
return getTransport() + "://" + getHost() + ":" + getPort();
40
public abstract String getTransport();
42
public String getHost()
53
public class TestCallbackHandler implements InvokerCallbackHandler
56
public void handleCallback(Callback callback) throws HandleCallbackException
58
System.out.println("callback = " + callback);