public class ScenarioHandler extends Thread {
private static final Logger LOGGER = LoggerFactory.getLogger(ScenarioHandler.class);
private Stack<ClientEvent> scenario;
private BlockingQueue<byte[]> ofMsg;
private ChannelHandlerContext ctx;
public class ScenarioHandler extends Thread {
private static final Logger LOGGER = LoggerFactory.getLogger(ScenarioHandler.class);
private Stack<ClientEvent> scenario;
private BlockingQueue<byte[]> ofMsg;
private ChannelHandlerContext ctx;
ClientEvent peek = scenario.peek();
if (peek instanceof WaitForMessageEvent) {
LOGGER.debug("WaitForMessageEvent");
ClientEvent peek = scenario.peek();
if (peek instanceof WaitForMessageEvent) {
LOGGER.debug("WaitForMessageEvent");