org.springframework.integration.core
Class AsyncMessagingTemplate
java.lang.Object
org.springframework.integration.core.MessagingTemplate
org.springframework.integration.core.AsyncMessagingTemplate
- All Implemented Interfaces:
- BeanFactoryAware, InitializingBean, AsyncMessagingOperations, MessagingOperations
public class AsyncMessagingTemplate
- extends MessagingTemplate
- implements AsyncMessagingOperations
- Since:
- 2.0
Method Summary |
java.util.concurrent.Future<?> |
asyncConvertAndSend(MessageChannel channel,
java.lang.Object object)
|
java.util.concurrent.Future<?> |
asyncConvertAndSend(java.lang.Object object)
|
java.util.concurrent.Future<?> |
asyncConvertAndSend(java.lang.String channelName,
java.lang.Object object)
|
<R> java.util.concurrent.Future<R> |
|
asyncConvertSendAndReceive(MessageChannel channel,
java.lang.Object request)
|
<R> java.util.concurrent.Future<R> |
|
asyncConvertSendAndReceive(MessageChannel channel,
java.lang.Object request,
MessagePostProcessor requestPostProcessor)
|
<R> java.util.concurrent.Future<R> |
|
asyncConvertSendAndReceive(java.lang.Object request)
|
<R> java.util.concurrent.Future<R> |
|
asyncConvertSendAndReceive(java.lang.Object request,
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,
MessagePostProcessor requestPostProcessor)
|
java.util.concurrent.Future<Message<?>> |
asyncReceive()
|
java.util.concurrent.Future<Message<?>> |
asyncReceive(PollableChannel channel)
|
java.util.concurrent.Future<Message<?>> |
asyncReceive(java.lang.String channelName)
|
<R> java.util.concurrent.Future<R> |
|
asyncReceiveAndConvert()
|
<R> java.util.concurrent.Future<R> |
|
asyncReceiveAndConvert(PollableChannel channel)
|
<R> java.util.concurrent.Future<R> |
|
asyncReceiveAndConvert(java.lang.String channelName)
|
java.util.concurrent.Future<?> |
asyncSend(Message<?> message)
|
java.util.concurrent.Future<?> |
asyncSend(MessageChannel channel,
Message<?> message)
|
java.util.concurrent.Future<?> |
asyncSend(java.lang.String channelName,
Message<?> message)
|
java.util.concurrent.Future<Message<?>> |
asyncSendAndReceive(Message<?> requestMessage)
|
java.util.concurrent.Future<Message<?>> |
asyncSendAndReceive(MessageChannel channel,
Message<?> requestMessage)
|
java.util.concurrent.Future<Message<?>> |
asyncSendAndReceive(java.lang.String channelName,
Message<?> requestMessage)
|
void |
setExecutor(java.util.concurrent.Executor executor)
|
Methods inherited from class org.springframework.integration.core.MessagingTemplate |
afterPropertiesSet, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, receive, receive, receive, receiveAndConvert, receiveAndConvert, receiveAndConvert, resolveChannelName, send, send, send, sendAndReceive, sendAndReceive, sendAndReceive, setBeanFactory, setChannelResolver, setDefaultChannel, setMessageConverter, setReceiveTimeout, setSendTimeout |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AsyncMessagingTemplate
public AsyncMessagingTemplate()
setExecutor
public void setExecutor(java.util.concurrent.Executor executor)
asyncSend
public java.util.concurrent.Future<?> asyncSend(Message<?> message)
- Specified by:
asyncSend
in interface AsyncMessagingOperations
asyncSend
public java.util.concurrent.Future<?> asyncSend(MessageChannel channel,
Message<?> message)
- Specified by:
asyncSend
in interface AsyncMessagingOperations
asyncSend
public java.util.concurrent.Future<?> asyncSend(java.lang.String channelName,
Message<?> message)
- Specified by:
asyncSend
in interface AsyncMessagingOperations
asyncConvertAndSend
public java.util.concurrent.Future<?> asyncConvertAndSend(java.lang.Object object)
- Specified by:
asyncConvertAndSend
in interface AsyncMessagingOperations
asyncConvertAndSend
public java.util.concurrent.Future<?> asyncConvertAndSend(MessageChannel channel,
java.lang.Object object)
- Specified by:
asyncConvertAndSend
in interface AsyncMessagingOperations
asyncConvertAndSend
public java.util.concurrent.Future<?> asyncConvertAndSend(java.lang.String channelName,
java.lang.Object object)
- Specified by:
asyncConvertAndSend
in interface AsyncMessagingOperations
asyncReceive
public java.util.concurrent.Future<Message<?>> asyncReceive()
- Specified by:
asyncReceive
in interface AsyncMessagingOperations
asyncReceive
public java.util.concurrent.Future<Message<?>> asyncReceive(PollableChannel channel)
- Specified by:
asyncReceive
in interface AsyncMessagingOperations
asyncReceive
public java.util.concurrent.Future<Message<?>> asyncReceive(java.lang.String channelName)
- Specified by:
asyncReceive
in interface AsyncMessagingOperations
asyncReceiveAndConvert
public <R> java.util.concurrent.Future<R> asyncReceiveAndConvert()
- Specified by:
asyncReceiveAndConvert
in interface AsyncMessagingOperations
asyncReceiveAndConvert
public <R> java.util.concurrent.Future<R> asyncReceiveAndConvert(PollableChannel channel)
- Specified by:
asyncReceiveAndConvert
in interface AsyncMessagingOperations
asyncReceiveAndConvert
public <R> java.util.concurrent.Future<R> asyncReceiveAndConvert(java.lang.String channelName)
- Specified by:
asyncReceiveAndConvert
in interface AsyncMessagingOperations
asyncSendAndReceive
public java.util.concurrent.Future<Message<?>> asyncSendAndReceive(Message<?> requestMessage)
- Specified by:
asyncSendAndReceive
in interface AsyncMessagingOperations
asyncSendAndReceive
public java.util.concurrent.Future<Message<?>> asyncSendAndReceive(MessageChannel channel,
Message<?> requestMessage)
- Specified by:
asyncSendAndReceive
in interface AsyncMessagingOperations
asyncSendAndReceive
public java.util.concurrent.Future<Message<?>> asyncSendAndReceive(java.lang.String channelName,
Message<?> requestMessage)
- Specified by:
asyncSendAndReceive
in interface AsyncMessagingOperations
asyncConvertSendAndReceive
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.Object request)
- Specified by:
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
asyncConvertSendAndReceive
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(MessageChannel channel,
java.lang.Object request)
- Specified by:
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
asyncConvertSendAndReceive
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.String channelName,
java.lang.Object request)
- Specified by:
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
asyncConvertSendAndReceive
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.Object request,
MessagePostProcessor requestPostProcessor)
- Specified by:
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
asyncConvertSendAndReceive
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(MessageChannel channel,
java.lang.Object request,
MessagePostProcessor requestPostProcessor)
- Specified by:
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
asyncConvertSendAndReceive
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.String channelName,
java.lang.Object request,
MessagePostProcessor requestPostProcessor)
- Specified by:
asyncConvertSendAndReceive
in interface AsyncMessagingOperations