// WriteTimeoutHandler & ReadTimeoutHandler
p.addLast("readTimeoutHandler", new ReadTimeoutHandler(
readTimeoutMs, TimeUnit.MILLISECONDS));
p.addLast(new StringEncoder(CharsetUtil.UTF_8));
p.addLast(new SnappyFramedDecoder(true));
p.addLast(new RecordIdDecoder(store));
p.addLast(executor, handler);
}
});
state = STATUS_RUNNING;
this.running = true;