public class ReconfigurationPacketDemultiplexer extends AbstractPacketDemultiplexer<Request>
AbstractPacketDemultiplexer.TaskerDEFAULT_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, toStringpublic ReconfigurationPacketDemultiplexer(Stringifiable<?> unstringer, AppRequestParser arp)
unstringer - arp - public ReconfigurationPacketDemultiplexer(Stringifiable<?> unstringer)
unstringer - public ReconfigurationPacketDemultiplexer setAppRequestParser(AppRequestParser parser)
parser - thispublic 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>