1
package org.jboss.test.remoting.transport.socket.connection.retry;
3
import org.jboss.jrunit.extensions.ServerTestCase;
4
import org.jboss.remoting.InvocationRequest;
5
import org.jboss.remoting.ServerInvocationHandler;
6
import org.jboss.remoting.ServerInvoker;
7
import org.jboss.remoting.callback.InvokerCallbackHandler;
8
import org.jboss.remoting.transport.Connector;
9
import org.jboss.remoting.transport.socket.SocketClientInvoker;
10
import org.jboss.remoting.transport.socket.SocketServerInvoker;
12
import javax.management.MBeanServer;
15
* @author <a href="mailto:tom.elrod@jboss.com">Tom Elrod</a>
17
public class SocketRetryServer extends ServerTestCase
19
private Connector connector = null;
22
public void setUp() throws Exception
24
String locatorUri = getTransport() + "://localhost:" + getPort() + "/?" + SocketClientInvoker.SO_TIMEOUT_FLAG + "=" + 1000 + "&" +
25
SocketServerInvoker.CHECK_CONNECTION_KEY + "=" + Boolean.FALSE;
27
connector = new Connector(locatorUri);
29
connector.addInvocationHandler("test", new TestInvocationHandler());
34
public void tearDown()
36
if (connector != null)
43
public static void main(String[] args)
45
SocketRetryServer server = new SocketRetryServer();
62
protected String getTransport()
67
protected int getPort()
72
public class TestInvocationHandler implements ServerInvocationHandler
75
public void setMBeanServer(MBeanServer server)
77
//TODO: -TME Implement
80
public void setInvoker(ServerInvoker invoker)
82
//TODO: -TME Implement
85
public Object invoke(InvocationRequest invocation) throws Throwable
90
public void addListener(InvokerCallbackHandler callbackHandler)
92
//TODO: -TME Implement
95
public void removeListener(InvokerCallbackHandler callbackHandler)
97
//TODO: -TME Implement