public class QueueingMessageProcessingStrategy extends java.lang.Object implements MessageProcessingStrategy
Constructor and Description |
---|
QueueingMessageProcessingStrategy(java.util.Queue<ByteMessage> messageQueue)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
processMessage(byte[] message)
A hook to allow implementations to do do something with the message when
it has been completely received from the socket
|
public QueueingMessageProcessingStrategy(java.util.Queue<ByteMessage> messageQueue)
socket
- messageQueue
- public void processMessage(byte[] message)
MessageProcessingStrategy
processMessage
in interface MessageProcessingStrategy
message
- The complete message