public class PubSubMessageProcessingStrategy extends java.lang.Object implements MessageProcessingStrategy
Constructor and Description |
---|
PubSubMessageProcessingStrategy(java.util.Set<IPSessionEndpoint> subscribers) |
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 PubSubMessageProcessingStrategy(java.util.Set<IPSessionEndpoint> subscribers)
subscribers
- The set of subscribers to notify when there is a new messagepublic void processMessage(byte[] message)
MessageProcessingStrategy
processMessage
in interface MessageProcessingStrategy
message
- The complete message