public interface MessageProcessingPolicy
Modifier and Type | Method and Description |
---|---|
default void |
destroy()
Called before the transport is stopped
|
void |
init(TP transport)
Called after creation.
|
void |
loopback(Message msg,
boolean oob,
boolean internal)
Process a message that was not received from the transport but from above (e.g.
|
void |
process(MessageBatch batch,
boolean oob,
boolean internal)
Process a batch received from the transport
|
void |
process(Message msg,
boolean oob,
boolean internal)
Process a message received from the transport
|
default void |
reset()
To reset stats
|
void init(TP transport)
default void reset()
default void destroy()
void loopback(Message msg, boolean oob, boolean internal)
msg
- the message to be looped back up the stack.oob
- true if the message is an OOB messageinternal
- true if the message is internalvoid process(Message msg, boolean oob, boolean internal)
msg
- the messageoob
- true if the message is an OOB messageinternal
- true if the message is internalvoid process(MessageBatch batch, boolean oob, boolean internal)
batch
- the batchoob
- true if the batch contains only OOB messagesinternal
- true if the batch contains only internal messages (or internal and OOB messages)Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.