private class ExecutorSubscribableChannel.SendTask extends java.lang.Object implements MessageHandlingRunnable
Modifier and Type | Field and Description |
---|---|
private Message<?> |
inputMessage |
private int |
interceptorIndex |
private MessageHandler |
messageHandler |
Constructor and Description |
---|
SendTask(Message<?> message,
MessageHandler messageHandler) |
Modifier and Type | Method and Description |
---|---|
private Message<?> |
applyBeforeHandle(Message<?> message) |
Message<?> |
getMessage()
Return the Message that will be handled.
|
MessageHandler |
getMessageHandler()
Return the MessageHandler that will be used to handle the message.
|
void |
run() |
private void |
triggerAfterMessageHandled(Message<?> message,
java.lang.Exception ex) |
private final Message<?> inputMessage
private final MessageHandler messageHandler
private int interceptorIndex
public SendTask(Message<?> message, MessageHandler messageHandler)
public Message<?> getMessage()
MessageHandlingRunnable
getMessage
in interface MessageHandlingRunnable
public MessageHandler getMessageHandler()
MessageHandlingRunnable
getMessageHandler
in interface MessageHandlingRunnable
public void run()
run
in interface java.lang.Runnable
private void triggerAfterMessageHandled(Message<?> message, java.lang.Exception ex)