org.springframework.messaging.support

Class ExecutorSubscribableChannel.SendTask

java.lang.Object

org.springframework.messaging.support.ExecutorSubscribableChannel.SendTask

All Implemented Interfaces:

java.lang.Runnable, MessageHandlingRunnable

Enclosing class:

ExecutorSubscribableChannel

private class ExecutorSubscribableChannel.SendTask
extends java.lang.Object
implements MessageHandlingRunnable

Invoke a MessageHandler with ExecutorChannelInterceptor's.

Field Summary

Fields

Modifier and Type	Field and Description
private Message<?>	inputMessage
private int	interceptorIndex
private MessageHandler	messageHandler

Constructor Summary

Constructors

Constructor and Description
SendTask(Message<?> message, MessageHandler messageHandler)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

inputMessage

private final Message<?> inputMessage

messageHandler

private final MessageHandler messageHandler

interceptorIndex

private int interceptorIndex

Constructor Detail

SendTask

public SendTask(Message<?> message,
                MessageHandler messageHandler)

Method Detail

getMessage

public Message<?> getMessage()

Description copied from interface: MessageHandlingRunnable

Return the Message that will be handled.

Specified by:

getMessage in interface MessageHandlingRunnable

getMessageHandler

public MessageHandler getMessageHandler()

Description copied from interface: MessageHandlingRunnable

Return the MessageHandler that will be used to handle the message.

Specified by:

getMessageHandler in interface MessageHandlingRunnable

run

public void run()

Specified by:

run in interface java.lang.Runnable

applyBeforeHandle

private Message<?> applyBeforeHandle(Message<?> message)

triggerAfterMessageHandled

private void triggerAfterMessageHandled(Message<?> message,
                                        java.lang.Exception ex)