@Test public void reconnectHandlerTest() { WebSocketKieServerControllerReconnectHandler handler = new WebSocketKieServerControllerReconnectHandler(new KieServerRegistryImpl()); Assert.assertNotNull(handler.getNextHandler()); Assert.assertEquals(handler.getNextHandler().getClass(), CommandScriptMessageHandler.class); }
public InternalMessageHandler getNextHandler() { return new CommandScriptMessageHandler(context); }
WebSocketKieServerControllerReconnectHandler implements InternalMessageHandler { public InternalMessageHandler getNextHandler() { return new CommandScriptMessageHandler(context); } }
WebSocketKieServerControllerReconnectHandler implements InternalMessageHandler { public InternalMessageHandler getNextHandler() { return new CommandScriptMessageHandler(context); } WebSocketKieServerControllerReconnectHandler(KieServerRegistry context); }
WebSocketKieServerControllerReconnectHandler implements InternalMessageHandler { public InternalMessageHandler getNextHandler() { return new CommandScriptMessageHandler(context); } WebSocketKieServerControllerReconnectHandler(KieServerRegistry context); @Override String onMessage(String message); InternalMessageHandler getNextHandler(); }
WebSocketKieServerControllerReconnectHandler implements InternalMessageHandler { public InternalMessageHandler getNextHandler() { return new CommandScriptMessageHandler(context); } WebSocketKieServerControllerReconnectHandler(KieServerRegistry context); @Override String onMessage(String message); InternalMessageHandler getNextHandler();  }