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<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>
- Since:
- 2.0
- Author:
- Mark Fisher, Gary Russell
-
Field Summary
Fields inherited from class org.springframework.messaging.core.GenericMessagingTemplate
DEFAULT_RECEIVE_TIMEOUT_HEADER, DEFAULT_SEND_TIMEOUT_HEADER
Fields inherited from class org.springframework.messaging.core.AbstractMessageSendingTemplate
CONVERSION_HINT_HEADER, logger
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionFuture<?>
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) asyncReceive
(String channelName) asyncReceive
(PollableChannel channel) <R> Future<R>
<R> Future<R>
asyncReceiveAndConvert
(String channelName) <R> Future<R>
asyncReceiveAndConvert
(PollableChannel channel) Future<?>
Future<?>
Future<?>
asyncSend
(MessageChannel channel, Message<?> message) asyncSendAndReceive
(String channelName, Message<?> requestMessage) asyncSendAndReceive
(Message<?> requestMessage) asyncSendAndReceive
(MessageChannel channel, Message<?> requestMessage) void
setExecutor
(Executor executor) Methods inherited from class org.springframework.integration.core.MessagingTemplate
receive, receiveAndConvert, sendAndReceive, setBeanFactory, setDefaultChannel, setThrowExceptionOnLateReply
Methods inherited from class org.springframework.messaging.core.GenericMessagingTemplate
doReceive, doReceive, doSend, doSend, doSendAndReceive, getReceiveTimeout, getReceiveTimeoutHeader, getSendTimeout, getSendTimeoutHeader, setReceiveTimeout, setReceiveTimeoutHeader, setSendTimeout, setSendTimeoutHeader
Methods inherited from class org.springframework.messaging.core.AbstractDestinationResolvingMessagingTemplate
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, getDestinationResolver, receive, receiveAndConvert, resolveDestination, send, sendAndReceive, setDestinationResolver
Methods inherited from class org.springframework.messaging.core.AbstractMessagingTemplate
convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceive
Methods inherited from class org.springframework.messaging.core.AbstractMessageReceivingTemplate
doConvert, receive, receive, receiveAndConvert, receiveAndConvert
Methods inherited from class org.springframework.messaging.core.AbstractMessageSendingTemplate
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, doConvert, getDefaultDestination, getMessageConverter, getRequiredDefaultDestination, processHeadersToSend, send, send, setDefaultDestination, setMessageConverter
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.messaging.core.MessageReceivingOperations
receive, receive, receiveAndConvert, receiveAndConvert
Methods inherited from interface org.springframework.messaging.core.MessageRequestReplyOperations
convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceive
Methods 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:
asyncSend
in interfaceAsyncMessagingOperations
-
asyncSend
- Specified by:
asyncSend
in interfaceAsyncMessagingOperations
-
asyncSend
- Specified by:
asyncSend
in interfaceAsyncMessagingOperations
-
asyncConvertAndSend
- Specified by:
asyncConvertAndSend
in interfaceAsyncMessagingOperations
-
asyncConvertAndSend
- Specified by:
asyncConvertAndSend
in interfaceAsyncMessagingOperations
-
asyncConvertAndSend
- Specified by:
asyncConvertAndSend
in interfaceAsyncMessagingOperations
-
asyncReceive
- Specified by:
asyncReceive
in interfaceAsyncMessagingOperations
-
asyncReceive
- Specified by:
asyncReceive
in interfaceAsyncMessagingOperations
-
asyncReceive
- Specified by:
asyncReceive
in interfaceAsyncMessagingOperations
-
asyncReceiveAndConvert
- Specified by:
asyncReceiveAndConvert
in interfaceAsyncMessagingOperations
-
asyncReceiveAndConvert
- Specified by:
asyncReceiveAndConvert
in interfaceAsyncMessagingOperations
-
asyncReceiveAndConvert
- Specified by:
asyncReceiveAndConvert
in interfaceAsyncMessagingOperations
-
asyncSendAndReceive
- Specified by:
asyncSendAndReceive
in interfaceAsyncMessagingOperations
-
asyncSendAndReceive
- Specified by:
asyncSendAndReceive
in interfaceAsyncMessagingOperations
-
asyncSendAndReceive
- Specified by:
asyncSendAndReceive
in interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
- Specified by:
asyncConvertSendAndReceive
in interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
- Specified by:
asyncConvertSendAndReceive
in interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
- Specified by:
asyncConvertSendAndReceive
in interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
public <R> Future<R> asyncConvertSendAndReceive(Object request, MessagePostProcessor requestPostProcessor) - Specified by:
asyncConvertSendAndReceive
in interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
public <R> Future<R> asyncConvertSendAndReceive(MessageChannel channel, Object request, MessagePostProcessor requestPostProcessor) - Specified by:
asyncConvertSendAndReceive
in interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
public <R> Future<R> asyncConvertSendAndReceive(String channelName, Object request, MessagePostProcessor requestPostProcessor) - Specified by:
asyncConvertSendAndReceive
in interfaceAsyncMessagingOperations
-