public class DemuxingProtocolHandler extends ProtocolHandlerAdapter
ProtocolHandler
that demuxes messageReceived
events
to the appropriate MessageHandler
.
You can freely register and deregister MessageHandler
s using
addMessageHandler(Class, MessageHandler)
and
removeMessageHandler(Class)
.Modifier | Constructor and Description |
---|---|
protected |
DemuxingProtocolHandler()
Creates a new instance with no registered
MessageHandler s. |
Modifier and Type | Method and Description |
---|---|
MessageHandler |
addMessageHandler(java.lang.Class type,
MessageHandler handler)
Registers a
MessageHandler that receives the messages of
the specified type . |
MessageHandler |
getMessageHandler(java.lang.Class type)
Returns the
MessageHandler which is registered to process
the specified type . |
java.util.Map |
getMessageHandlerMap()
Returns the
Map which contains all messageType-MessageHandler
pairs registered to this handler. |
void |
messageReceived(ProtocolSession session,
java.lang.Object message)
Forwards the received events into the appropriate
MessageHandler
which is registered by addMessageHandler(Class, MessageHandler) . |
MessageHandler |
removeMessageHandler(java.lang.Class type)
Deregisters a
MessageHandler that receives the messages of
the specified type . |
exceptionCaught, messageSent, sessionClosed, sessionCreated, sessionIdle, sessionOpened
protected DemuxingProtocolHandler()
MessageHandler
s.public MessageHandler addMessageHandler(java.lang.Class type, MessageHandler handler)
MessageHandler
that receives the messages of
the specified type
.public MessageHandler removeMessageHandler(java.lang.Class type)
MessageHandler
that receives the messages of
the specified type
.public MessageHandler getMessageHandler(java.lang.Class type)
MessageHandler
which is registered to process
the specified type
.public java.util.Map getMessageHandlerMap()
Map
which contains all messageType-MessageHandler
pairs registered to this handler.public void messageReceived(ProtocolSession session, java.lang.Object message) throws java.lang.Exception
MessageHandler
which is registered by addMessageHandler(Class, MessageHandler)
.messageReceived
in interface ProtocolHandler
messageReceived
in class ProtocolHandlerAdapter
java.lang.Exception