1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
package org.jboss.test.remoting.callback.push.unidirectional;
import junit.framework.TestCase;
import org.jboss.remoting.Client;
import org.jboss.remoting.InvokerLocator;
import org.jboss.remoting.callback.Callback;
import org.jboss.remoting.callback.CallbackPoller;
import org.jboss.remoting.callback.HandleCallbackException;
import org.jboss.remoting.callback.InvokerCallbackHandler;
import java.util.HashMap;
import java.util.Map;
/**
* @author <a href="mailto:tom.elrod@jboss.com">Tom Elrod</a>
*/
public abstract class CallbackPollTestClient extends TestCase
{
private boolean gotCallback = false;
public void testCallback() throws Throwable
{
Client client = new Client(new InvokerLocator(getLocatorUri()));
client.connect();
InvokerCallbackHandler testCallbackHandler = new TestCallbackHandler();
Map metadata = new HashMap();
metadata.put(CallbackPoller.CALLBACK_POLL_PERIOD, "1000");
client.addListener(testCallbackHandler, metadata, "foobar");
client.invoke("foobar");
Thread.sleep(4000);
//Thread.sleep(600000);
client.removeListener(testCallbackHandler);
client.disconnect();
assertTrue(gotCallback);
}
private String getLocatorUri()
{
return getTransport() + "://" + getHost() + ":" + getPort();
}
public abstract String getTransport();
public String getHost()
{
return "localhost";
}
public int getPort()
{
return 6999;
}
public class TestCallbackHandler implements InvokerCallbackHandler
{
public void handleCallback(Callback callback) throws HandleCallbackException
{
System.out.println("callback = " + callback);
Object o = callback.getCallbackHandleObject();
if ("foobar".equals(o))
{
gotCallback = true;
}
else
{
System.out.println("CallbackHandleObject was " + o + " and not 'foobar'");
}
}
}
}
|
