public class SubmitToThreadPool extends Object implements MessageProcessingPolicy
Modifier and Type | Class and Description |
---|---|
protected class |
SubmitToThreadPool.BatchHandler |
protected class |
SubmitToThreadPool.SingleMessageHandler |
protected class |
SubmitToThreadPool.SingleMessageHandlerWithClusterName |
Modifier and Type | Field and Description |
---|---|
protected Log |
log |
protected TP |
tp |
protected short |
tp_id |
Constructor and Description |
---|
SubmitToThreadPool() |
Modifier and Type | Method and Description |
---|---|
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
|
protected void |
removeAndDispatchNonBundledMessages(MessageBatch oob_batch)
Removes messages with flags DONT_BUNDLE and OOB set and executes them in the oob or internal thread pool.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
destroy, reset
public void init(TP transport)
MessageProcessingPolicy
init
in interface MessageProcessingPolicy
public void loopback(Message msg, boolean oob, boolean internal)
MessageProcessingPolicy
loopback
in interface MessageProcessingPolicy
msg
- the message to be looped back up the stack.oob
- true if the message is an OOB messageinternal
- true if the message is internalpublic void process(Message msg, boolean oob, boolean internal)
MessageProcessingPolicy
process
in interface MessageProcessingPolicy
msg
- the messageoob
- true if the message is an OOB messageinternal
- true if the message is internalpublic void process(MessageBatch batch, boolean oob, boolean internal)
MessageProcessingPolicy
process
in interface MessageProcessingPolicy
batch
- the batchoob
- true if the batch contains only OOB messagesinternal
- true if the batch contains only internal messages (or internal and OOB messages)protected void removeAndDispatchNonBundledMessages(MessageBatch oob_batch)
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.