Class AsyncMessagingTemplate

java.lang.Object

org.springframework.messaging.core.AbstractMessageSendingTemplate<MessageChannel>

org.springframework.messaging.core.AbstractMessageReceivingTemplate<MessageChannel>

org.springframework.messaging.core.AbstractMessagingTemplate<MessageChannel>

org.springframework.messaging.core.AbstractDestinationResolvingMessagingTemplate<MessageChannel>

org.springframework.messaging.core.GenericMessagingTemplate

org.springframework.integration.core.MessagingTemplate

org.springframework.integration.core.AsyncMessagingTemplate

All Implemented Interfaces:

Aware, BeanFactoryAware, AsyncMessagingOperations, DestinationResolvingMessageReceivingOperations<MessageChannel>, DestinationResolvingMessageRequestReplyOperations<MessageChannel>, DestinationResolvingMessageSendingOperations<MessageChannel>, MessageReceivingOperations<MessageChannel>, MessageRequestReplyOperations<MessageChannel>, MessageSendingOperations<MessageChannel>

public class AsyncMessagingTemplate
extends MessagingTemplate
implements AsyncMessagingOperations

Since:

2.0

Author:

Mark Fisher, Gary Russell, Ngoc Nhan

Field Summary

Fields inherited from class GenericMessagingTemplate

DEFAULT_RECEIVE_TIMEOUT_HEADER, DEFAULT_SEND_TIMEOUT_HEADER

Fields inherited from class AbstractMessageSendingTemplate

CONVERSION_HINT_HEADER, logger

Constructor Summary

Constructors

Constructor	Description
AsyncMessagingTemplate()

Method Summary

Modifier and Type	Method	Description
Future<?>	asyncConvertAndSend(Object object)
Future<?>	asyncConvertAndSend(String channelName, Object object)
Future<?>	asyncConvertAndSend(MessageChannel channel, Object object)
<R> Future<R>	asyncConvertSendAndReceive(Object request)
<R> Future<R>	asyncConvertSendAndReceive(Object request, MessagePostProcessor requestPostProcessor)
<R> Future<R>	asyncConvertSendAndReceive(String channelName, Object request)
<R> Future<R>	asyncConvertSendAndReceive(String channelName, Object request, MessagePostProcessor requestPostProcessor)
<R> Future<R>	asyncConvertSendAndReceive(MessageChannel channel, Object request)
<R> Future<R>	asyncConvertSendAndReceive(MessageChannel channel, Object request, MessagePostProcessor requestPostProcessor)
Future<Message<?>>	asyncReceive()
Future<Message<?>>	asyncReceive(String channelName)
Future<Message<?>>	asyncReceive(PollableChannel channel)
<R> Future<R>	asyncReceiveAndConvert()
<R> Future<R>	asyncReceiveAndConvert(String channelName)
<R> Future<R>	asyncReceiveAndConvert(PollableChannel channel)
Future<?>	asyncSend(String channelName, Message<?> message)
Future<?>	asyncSend(Message<?> message)
Future<?>	asyncSend(MessageChannel channel, Message<?> message)
Future<Message<?>>	asyncSendAndReceive(String channelName, Message<?> requestMessage)
Future<Message<?>>	asyncSendAndReceive(Message<?> requestMessage)
Future<Message<?>>	asyncSendAndReceive(MessageChannel channel, Message<?> requestMessage)
void	setExecutor(Executor executor)

Methods inherited from class MessagingTemplate

receive, receiveAndConvert, sendAndReceive, setBeanFactory, setDefaultChannel, setThrowExceptionOnLateReply

Methods inherited from class GenericMessagingTemplate

doReceive, doReceive, doSend, doSend, doSendAndReceive, getReceiveTimeout, getReceiveTimeoutHeader, getSendTimeout, getSendTimeoutHeader, setReceiveTimeout, setReceiveTimeoutHeader, setSendTimeout, setSendTimeoutHeader

Methods inherited from class AbstractDestinationResolvingMessagingTemplate

convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, getDestinationResolver, receive, receiveAndConvert, resolveDestination, send, sendAndReceive, setDestinationResolver

Methods inherited from class AbstractMessagingTemplate

convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceive

Methods inherited from class AbstractMessageReceivingTemplate

doConvert, receive, receive, receiveAndConvert, receiveAndConvert

Methods inherited from class AbstractMessageSendingTemplate

convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, doConvert, getDefaultDestination, getMessageConverter, getRequiredDefaultDestination, processHeadersToSend, send, send, setDefaultDestination, setMessageConverter

Methods inherited from class Object

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

Methods inherited from interface MessageReceivingOperations

receive, receive, receiveAndConvert, receiveAndConvert

Methods inherited from interface MessageRequestReplyOperations

convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceive

Methods inherited from interface MessageSendingOperations

convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, send, send

Constructor Details

AsyncMessagingTemplate

public AsyncMessagingTemplate()

Method Details

setExecutor

public void setExecutor(Executor executor)

asyncSend

public Future<?> asyncSend(Message<?> message)

Specified by:

asyncSend in interface AsyncMessagingOperations

asyncSend

public Future<?> asyncSend(MessageChannel channel,
 Message<?> message)

Specified by:

asyncSend in interface AsyncMessagingOperations

asyncSend

public Future<?> asyncSend(String channelName,
 Message<?> message)

Specified by:

asyncSend in interface AsyncMessagingOperations

asyncConvertAndSend

public Future<?> asyncConvertAndSend(Object object)

Specified by:

asyncConvertAndSend in interface AsyncMessagingOperations

asyncConvertAndSend

public Future<?> asyncConvertAndSend(MessageChannel channel,
 Object object)

Specified by:

asyncConvertAndSend in interface AsyncMessagingOperations

asyncConvertAndSend

public Future<?> asyncConvertAndSend(String channelName,
 Object object)

Specified by:

asyncConvertAndSend in interface AsyncMessagingOperations

asyncReceive

public Future<Message<?>> asyncReceive()

Specified by:

asyncReceive in interface AsyncMessagingOperations

asyncReceive

public Future<Message<?>> asyncReceive(PollableChannel channel)

Specified by:

asyncReceive in interface AsyncMessagingOperations

asyncReceive

public Future<Message<?>> asyncReceive(String channelName)

Specified by:

asyncReceive in interface AsyncMessagingOperations

asyncReceiveAndConvert

public <R> Future<R> asyncReceiveAndConvert()

Specified by:

asyncReceiveAndConvert in interface AsyncMessagingOperations

asyncReceiveAndConvert

public <R> Future<R> asyncReceiveAndConvert(PollableChannel channel)

Specified by:

asyncReceiveAndConvert in interface AsyncMessagingOperations

asyncReceiveAndConvert

public <R> Future<R> asyncReceiveAndConvert(String channelName)

Specified by:

asyncReceiveAndConvert in interface AsyncMessagingOperations

asyncSendAndReceive

public Future<Message<?>> asyncSendAndReceive(Message<?> requestMessage)

Specified by:

asyncSendAndReceive in interface AsyncMessagingOperations

asyncSendAndReceive

public Future<Message<?>> asyncSendAndReceive(MessageChannel channel,
 Message<?> requestMessage)

Specified by:

asyncSendAndReceive in interface AsyncMessagingOperations

asyncSendAndReceive

public Future<Message<?>> asyncSendAndReceive(String channelName,
 Message<?> requestMessage)

Specified by:

asyncSendAndReceive in interface AsyncMessagingOperations

asyncConvertSendAndReceive

public <R> Future<R> asyncConvertSendAndReceive(Object request)

Specified by:

asyncConvertSendAndReceive in interface AsyncMessagingOperations

asyncConvertSendAndReceive

public <R> Future<R> asyncConvertSendAndReceive(MessageChannel channel,
 Object request)

Specified by:

asyncConvertSendAndReceive in interface AsyncMessagingOperations

asyncConvertSendAndReceive

public <R> Future<R> asyncConvertSendAndReceive(String channelName,
 Object request)

Specified by:

asyncConvertSendAndReceive in interface AsyncMessagingOperations

asyncConvertSendAndReceive

public <R> Future<R> asyncConvertSendAndReceive(Object request,
 MessagePostProcessor requestPostProcessor)

Specified by:

asyncConvertSendAndReceive in interface AsyncMessagingOperations

asyncConvertSendAndReceive

public <R> Future<R> asyncConvertSendAndReceive(MessageChannel channel,
 Object request,
 MessagePostProcessor requestPostProcessor)

Specified by:

asyncConvertSendAndReceive in interface AsyncMessagingOperations

asyncConvertSendAndReceive

public <R> Future<R> asyncConvertSendAndReceive(String channelName,
 Object request,
 MessagePostProcessor requestPostProcessor)

Specified by:

asyncConvertSendAndReceive in interface AsyncMessagingOperations