org.springframework.integration.core
Class AsyncMessagingTemplate

java.lang.Object
  extended by org.springframework.integration.core.MessagingTemplate
      extended by org.springframework.integration.core.AsyncMessagingTemplate
All Implemented Interfaces:
BeanFactoryAware, InitializingBean, AsyncMessagingOperations, MessagingOperations

public class AsyncMessagingTemplate
extends MessagingTemplate
implements AsyncMessagingOperations

Since:
2.0

Field Summary
 
Fields inherited from class org.springframework.integration.core.MessagingTemplate
logger
 
Constructor Summary
AsyncMessagingTemplate()
           
 
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
 

Constructor Detail

AsyncMessagingTemplate

public AsyncMessagingTemplate()
Method Detail

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