Class AsyncMessagingTemplate
java.lang.Object
org.springframework.messaging.core.AbstractMessageSendingTemplate<D>
org.springframework.messaging.core.AbstractMessageReceivingTemplate<D>
org.springframework.messaging.core.AbstractMessagingTemplate<D>
org.springframework.messaging.core.AbstractDestinationResolvingMessagingTemplate<org.springframework.messaging.MessageChannel>
org.springframework.messaging.core.GenericMessagingTemplate
org.springframework.integration.core.MessagingTemplate
org.springframework.integration.core.AsyncMessagingTemplate
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,AsyncMessagingOperations,org.springframework.messaging.core.DestinationResolvingMessageReceivingOperations<org.springframework.messaging.MessageChannel>,org.springframework.messaging.core.DestinationResolvingMessageRequestReplyOperations<org.springframework.messaging.MessageChannel>,org.springframework.messaging.core.DestinationResolvingMessageSendingOperations<org.springframework.messaging.MessageChannel>,org.springframework.messaging.core.MessageReceivingOperations<org.springframework.messaging.MessageChannel>,org.springframework.messaging.core.MessageRequestReplyOperations<org.springframework.messaging.MessageChannel>,org.springframework.messaging.core.MessageSendingOperations<org.springframework.messaging.MessageChannel>
- Since:
- 2.0
-
Field Summary
Fields inherited from class org.springframework.messaging.core.GenericMessagingTemplate
DEFAULT_RECEIVE_TIMEOUT_HEADER, DEFAULT_SEND_TIMEOUT_HEADERFields inherited from class org.springframework.messaging.core.AbstractMessageSendingTemplate
CONVERSION_HINT_HEADER, logger -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionFuture<?>asyncConvertAndSend(Object object) Future<?>asyncConvertAndSend(String channelName, Object object) Future<?>asyncConvertAndSend(org.springframework.messaging.MessageChannel channel, Object object) <R> Future<R>asyncConvertSendAndReceive(Object request) <R> Future<R>asyncConvertSendAndReceive(Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor) <R> Future<R>asyncConvertSendAndReceive(String channelName, Object request) <R> Future<R>asyncConvertSendAndReceive(String channelName, Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor) <R> Future<R>asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, Object request) <R> Future<R>asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor) Future<org.springframework.messaging.Message<?>>Future<org.springframework.messaging.Message<?>>asyncReceive(String channelName) Future<org.springframework.messaging.Message<?>>asyncReceive(org.springframework.messaging.PollableChannel channel) <R> Future<R><R> Future<R>asyncReceiveAndConvert(String channelName) <R> Future<R>asyncReceiveAndConvert(org.springframework.messaging.PollableChannel channel) Future<?>Future<?>asyncSend(org.springframework.messaging.Message<?> message) Future<?>asyncSend(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> message) Future<org.springframework.messaging.Message<?>>asyncSendAndReceive(String channelName, org.springframework.messaging.Message<?> requestMessage) Future<org.springframework.messaging.Message<?>>asyncSendAndReceive(org.springframework.messaging.Message<?> requestMessage) Future<org.springframework.messaging.Message<?>>asyncSendAndReceive(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> requestMessage) voidsetExecutor(Executor executor) Methods inherited from class org.springframework.integration.core.MessagingTemplate
receive, receiveAndConvert, sendAndReceive, setBeanFactory, setDefaultChannel, setThrowExceptionOnLateReplyMethods inherited from class org.springframework.messaging.core.GenericMessagingTemplate
doReceive, doReceive, doSend, doSend, doSendAndReceive, getReceiveTimeout, getReceiveTimeoutHeader, getSendTimeout, getSendTimeoutHeader, setReceiveTimeout, setReceiveTimeoutHeader, setSendTimeout, setSendTimeoutHeaderMethods inherited from class org.springframework.messaging.core.AbstractDestinationResolvingMessagingTemplate
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, getDestinationResolver, receive, receiveAndConvert, resolveDestination, send, sendAndReceive, setDestinationResolverMethods inherited from class org.springframework.messaging.core.AbstractMessagingTemplate
convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceiveMethods inherited from class org.springframework.messaging.core.AbstractMessageReceivingTemplate
doConvert, receive, receive, receiveAndConvert, receiveAndConvertMethods inherited from class org.springframework.messaging.core.AbstractMessageSendingTemplate
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, doConvert, getDefaultDestination, getMessageConverter, getRequiredDefaultDestination, processHeadersToSend, send, send, setDefaultDestination, setMessageConverterMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.messaging.core.MessageReceivingOperations
receive, receive, receiveAndConvert, receiveAndConvertMethods inherited from interface org.springframework.messaging.core.MessageRequestReplyOperations
convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceiveMethods inherited from interface org.springframework.messaging.core.MessageSendingOperations
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, send, send
-
Constructor Details
-
AsyncMessagingTemplate
public AsyncMessagingTemplate()
-
-
Method Details
-
setExecutor
-
asyncSend
- Specified by:
asyncSendin interfaceAsyncMessagingOperations
-
asyncSend
public Future<?> asyncSend(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> message) - Specified by:
asyncSendin interfaceAsyncMessagingOperations
-
asyncSend
- Specified by:
asyncSendin interfaceAsyncMessagingOperations
-
asyncConvertAndSend
- Specified by:
asyncConvertAndSendin interfaceAsyncMessagingOperations
-
asyncConvertAndSend
public Future<?> asyncConvertAndSend(org.springframework.messaging.MessageChannel channel, Object object) - Specified by:
asyncConvertAndSendin interfaceAsyncMessagingOperations
-
asyncConvertAndSend
- Specified by:
asyncConvertAndSendin interfaceAsyncMessagingOperations
-
asyncReceive
- Specified by:
asyncReceivein interfaceAsyncMessagingOperations
-
asyncReceive
public Future<org.springframework.messaging.Message<?>> asyncReceive(org.springframework.messaging.PollableChannel channel) - Specified by:
asyncReceivein interfaceAsyncMessagingOperations
-
asyncReceive
- Specified by:
asyncReceivein interfaceAsyncMessagingOperations
-
asyncReceiveAndConvert
- Specified by:
asyncReceiveAndConvertin interfaceAsyncMessagingOperations
-
asyncReceiveAndConvert
- Specified by:
asyncReceiveAndConvertin interfaceAsyncMessagingOperations
-
asyncReceiveAndConvert
- Specified by:
asyncReceiveAndConvertin interfaceAsyncMessagingOperations
-
asyncSendAndReceive
public Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(org.springframework.messaging.Message<?> requestMessage) - Specified by:
asyncSendAndReceivein interfaceAsyncMessagingOperations
-
asyncSendAndReceive
public Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> requestMessage) - Specified by:
asyncSendAndReceivein interfaceAsyncMessagingOperations
-
asyncSendAndReceive
public Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(String channelName, org.springframework.messaging.Message<?> requestMessage) - Specified by:
asyncSendAndReceivein interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
- Specified by:
asyncConvertSendAndReceivein interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
public <R> Future<R> asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, Object request) - Specified by:
asyncConvertSendAndReceivein interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
- Specified by:
asyncConvertSendAndReceivein interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
public <R> Future<R> asyncConvertSendAndReceive(Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor) - Specified by:
asyncConvertSendAndReceivein interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
public <R> Future<R> asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor) - Specified by:
asyncConvertSendAndReceivein interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
public <R> Future<R> asyncConvertSendAndReceive(String channelName, Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor) - Specified by:
asyncConvertSendAndReceivein interfaceAsyncMessagingOperations
-