public class ReconfigurationPacketDemultiplexer extends AbstractPacketDemultiplexer<Request>
AbstractPacketDemultiplexer.Tasker
DEFAULT_THREAD_POOL_SIZE, log
Constructor and Description |
---|
ReconfigurationPacketDemultiplexer(Stringifiable<?> unstringer) |
ReconfigurationPacketDemultiplexer(Stringifiable<?> unstringer,
AppRequestParser arp) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Integer |
getPacketType(Request message) |
boolean |
handleMessage(Request message,
NIOHeader header) |
protected boolean |
matchesType(java.lang.Object message) |
protected Request |
processHeader(byte[] message,
NIOHeader header) |
ReconfigurationPacketDemultiplexer |
setAppRequestParser(AppRequestParser parser) |
ReconfigurationPacketDemultiplexer |
setThreadName(java.lang.String name) |
emulateDelays, getHandleMessageReport, getThreadPoolSize, handleMessageSuper, isCongested, isOrderPreserving, loopback, register, register, register, register, register, register, registerOrderPreserving, setNumDemultiplexerThreads, setThreadPoolSize, stop, toString
public ReconfigurationPacketDemultiplexer(Stringifiable<?> unstringer, AppRequestParser arp)
unstringer
- arp
- public ReconfigurationPacketDemultiplexer(Stringifiable<?> unstringer)
unstringer
- public ReconfigurationPacketDemultiplexer setAppRequestParser(AppRequestParser parser)
parser
- this
public ReconfigurationPacketDemultiplexer setThreadName(java.lang.String name)
setThreadName
in class AbstractPacketDemultiplexer<Request>
protected java.lang.Integer getPacketType(Request message)
getPacketType
in class AbstractPacketDemultiplexer<Request>
protected boolean matchesType(java.lang.Object message)
matchesType
in class AbstractPacketDemultiplexer<Request>
protected Request processHeader(byte[] message, NIOHeader header)
processHeader
in class AbstractPacketDemultiplexer<Request>