public class ServerTest {
public static final int PORT = 18080;
- DispatcherImpl clientDispatcher, dispatcher;
+ AbstractDispatcher clientDispatcher, dispatcher;
final SimpleSessionListener pce = new SimpleSessionListener();
@Test
public void testConnectionEstablished() throws Exception {
- this.dispatcher = new DispatcherImpl();
+ this.dispatcher = new AbstractDispatcher() { };
final Promise<Boolean> p = new DefaultPromise<>(GlobalEventExecutor.INSTANCE);
this.server.get();
- this.clientDispatcher = new DispatcherImpl();
+ this.clientDispatcher = new AbstractDispatcher() { };
this.session = this.clientDispatcher.createClient(this.serverAddress, new SimpleSessionListener(),
new SessionNegotiatorFactory<SimpleMessage, SimpleSession, SimpleSessionListener>() {
}
public void testConnectionFailed() throws IOException, InterruptedException {
- this.dispatcher = new DispatcherImpl();
- this.clientDispatcher = new DispatcherImpl();
+ this.dispatcher = new AbstractDispatcher() { };
+ this.clientDispatcher = new AbstractDispatcher() { };
final SimpleSessionListener listener = new SimpleSessionListener();
try {