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>
public class AsyncMessagingTemplate extends MessagingTemplate implements AsyncMessagingOperations
- Since:
- 2.0
-
Field Summary
-
Constructor Summary
Constructors Constructor Description AsyncMessagingTemplate() -
Method Summary
Modifier and Type Method Description java.util.concurrent.Future<?>asyncConvertAndSend(java.lang.Object object)java.util.concurrent.Future<?>asyncConvertAndSend(java.lang.String channelName, java.lang.Object object)java.util.concurrent.Future<?>asyncConvertAndSend(org.springframework.messaging.MessageChannel channel, java.lang.Object object)<R> java.util.concurrent.Future<R>asyncConvertSendAndReceive(java.lang.Object request)<R> java.util.concurrent.Future<R>asyncConvertSendAndReceive(java.lang.Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)<R> java.util.concurrent.Future<R>asyncConvertSendAndReceive(java.lang.String channelName, java.lang.Object request)<R> java.util.concurrent.Future<R>asyncConvertSendAndReceive(java.lang.String channelName, java.lang.Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)<R> java.util.concurrent.Future<R>asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, java.lang.Object request)<R> java.util.concurrent.Future<R>asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, java.lang.Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)java.util.concurrent.Future<org.springframework.messaging.Message<?>>asyncReceive()java.util.concurrent.Future<org.springframework.messaging.Message<?>>asyncReceive(java.lang.String channelName)java.util.concurrent.Future<org.springframework.messaging.Message<?>>asyncReceive(org.springframework.messaging.PollableChannel channel)<R> java.util.concurrent.Future<R>asyncReceiveAndConvert()<R> java.util.concurrent.Future<R>asyncReceiveAndConvert(java.lang.String channelName)<R> java.util.concurrent.Future<R>asyncReceiveAndConvert(org.springframework.messaging.PollableChannel channel)java.util.concurrent.Future<?>asyncSend(java.lang.String channelName, org.springframework.messaging.Message<?> message)java.util.concurrent.Future<?>asyncSend(org.springframework.messaging.Message<?> message)java.util.concurrent.Future<?>asyncSend(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> message)java.util.concurrent.Future<org.springframework.messaging.Message<?>>asyncSendAndReceive(java.lang.String channelName, org.springframework.messaging.Message<?> requestMessage)java.util.concurrent.Future<org.springframework.messaging.Message<?>>asyncSendAndReceive(org.springframework.messaging.Message<?> requestMessage)java.util.concurrent.Future<org.springframework.messaging.Message<?>>asyncSendAndReceive(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> requestMessage)voidsetExecutor(java.util.concurrent.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, receiveAndConvert
-
Constructor Details
-
AsyncMessagingTemplate
public AsyncMessagingTemplate()
-
-
Method Details
-
setExecutor
public void setExecutor(java.util.concurrent.Executor executor) -
asyncSend
public java.util.concurrent.Future<?> asyncSend(org.springframework.messaging.Message<?> message)- Specified by:
asyncSendin interfaceAsyncMessagingOperations
-
asyncSend
public java.util.concurrent.Future<?> asyncSend(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> message)- Specified by:
asyncSendin interfaceAsyncMessagingOperations
-
asyncSend
public java.util.concurrent.Future<?> asyncSend(java.lang.String channelName, org.springframework.messaging.Message<?> message)- Specified by:
asyncSendin interfaceAsyncMessagingOperations
-
asyncConvertAndSend
public java.util.concurrent.Future<?> asyncConvertAndSend(java.lang.Object object)- Specified by:
asyncConvertAndSendin interfaceAsyncMessagingOperations
-
asyncConvertAndSend
public java.util.concurrent.Future<?> asyncConvertAndSend(org.springframework.messaging.MessageChannel channel, java.lang.Object object)- Specified by:
asyncConvertAndSendin interfaceAsyncMessagingOperations
-
asyncConvertAndSend
public java.util.concurrent.Future<?> asyncConvertAndSend(java.lang.String channelName, java.lang.Object object)- Specified by:
asyncConvertAndSendin interfaceAsyncMessagingOperations
-
asyncReceive
public java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncReceive()- Specified by:
asyncReceivein interfaceAsyncMessagingOperations
-
asyncReceive
public java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncReceive(org.springframework.messaging.PollableChannel channel)- Specified by:
asyncReceivein interfaceAsyncMessagingOperations
-
asyncReceive
public java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncReceive(java.lang.String channelName)- Specified by:
asyncReceivein interfaceAsyncMessagingOperations
-
asyncReceiveAndConvert
public <R> java.util.concurrent.Future<R> asyncReceiveAndConvert()- Specified by:
asyncReceiveAndConvertin interfaceAsyncMessagingOperations
-
asyncReceiveAndConvert
public <R> java.util.concurrent.Future<R> asyncReceiveAndConvert(org.springframework.messaging.PollableChannel channel)- Specified by:
asyncReceiveAndConvertin interfaceAsyncMessagingOperations
-
asyncReceiveAndConvert
public <R> java.util.concurrent.Future<R> asyncReceiveAndConvert(java.lang.String channelName)- Specified by:
asyncReceiveAndConvertin interfaceAsyncMessagingOperations
-
asyncSendAndReceive
public java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(org.springframework.messaging.Message<?> requestMessage)- Specified by:
asyncSendAndReceivein interfaceAsyncMessagingOperations
-
asyncSendAndReceive
public java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> requestMessage)- Specified by:
asyncSendAndReceivein interfaceAsyncMessagingOperations
-
asyncSendAndReceive
public java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(java.lang.String channelName, org.springframework.messaging.Message<?> requestMessage)- Specified by:
asyncSendAndReceivein interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.Object request)- Specified by:
asyncConvertSendAndReceivein interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, java.lang.Object request)- Specified by:
asyncConvertSendAndReceivein interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.String channelName, java.lang.Object request)- Specified by:
asyncConvertSendAndReceivein interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)- Specified by:
asyncConvertSendAndReceivein interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, java.lang.Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)- Specified by:
asyncConvertSendAndReceivein interfaceAsyncMessagingOperations
-
asyncConvertSendAndReceive
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.String channelName, java.lang.Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)- Specified by:
asyncConvertSendAndReceivein interfaceAsyncMessagingOperations
-