public class AsyncMessagingTemplate extends MessagingTemplate implements AsyncMessagingOperations
logger| Constructor and Description |
|---|
AsyncMessagingTemplate() |
| Modifier and Type | Method and Description |
|---|---|
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) |
setBeanFactory, setDefaultChanneldoReceive, doSend, doSendAndReceive, getReceiveTimeout, getSendTimeout, setReceiveTimeout, setSendTimeout, setThrowExceptionOnLateReplyconvertAndSend, convertAndSend, convertAndSend, convertAndSend, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, getDestinationResolver, receive, receiveAndConvert, resolveDestination, send, sendAndReceive, setDestinationResolverconvertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, receive, receive, receiveAndConvert, receiveAndConvert, sendAndReceive, sendAndReceiveconvertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, getDefaultDestination, getMessageConverter, getRequiredDefaultDestination, processHeadersToSend, send, send, setDefaultDestination, setMessageConverterclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitconvertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, send, sendreceive, receive, receiveAndConvert, receiveAndConvertconvertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceive, sendAndReceivepublic void setExecutor(java.util.concurrent.Executor executor)
public java.util.concurrent.Future<?> asyncSend(Message<?> message)
asyncSend in interface AsyncMessagingOperationspublic java.util.concurrent.Future<?> asyncSend(MessageChannel channel, Message<?> message)
asyncSend in interface AsyncMessagingOperationspublic java.util.concurrent.Future<?> asyncSend(java.lang.String channelName,
Message<?> message)
asyncSend in interface AsyncMessagingOperationspublic java.util.concurrent.Future<?> asyncConvertAndSend(java.lang.Object object)
asyncConvertAndSend in interface AsyncMessagingOperationspublic java.util.concurrent.Future<?> asyncConvertAndSend(MessageChannel channel, java.lang.Object object)
asyncConvertAndSend in interface AsyncMessagingOperationspublic java.util.concurrent.Future<?> asyncConvertAndSend(java.lang.String channelName,
java.lang.Object object)
asyncConvertAndSend in interface AsyncMessagingOperationspublic java.util.concurrent.Future<Message<?>> asyncReceive()
asyncReceive in interface AsyncMessagingOperationspublic java.util.concurrent.Future<Message<?>> asyncReceive(PollableChannel channel)
asyncReceive in interface AsyncMessagingOperationspublic java.util.concurrent.Future<Message<?>> asyncReceive(java.lang.String channelName)
asyncReceive in interface AsyncMessagingOperationspublic <R> java.util.concurrent.Future<R> asyncReceiveAndConvert()
asyncReceiveAndConvert in interface AsyncMessagingOperationspublic <R> java.util.concurrent.Future<R> asyncReceiveAndConvert(PollableChannel channel)
asyncReceiveAndConvert in interface AsyncMessagingOperationspublic <R> java.util.concurrent.Future<R> asyncReceiveAndConvert(java.lang.String channelName)
asyncReceiveAndConvert in interface AsyncMessagingOperationspublic java.util.concurrent.Future<Message<?>> asyncSendAndReceive(Message<?> requestMessage)
asyncSendAndReceive in interface AsyncMessagingOperationspublic java.util.concurrent.Future<Message<?>> asyncSendAndReceive(MessageChannel channel, Message<?> requestMessage)
asyncSendAndReceive in interface AsyncMessagingOperationspublic java.util.concurrent.Future<Message<?>> asyncSendAndReceive(java.lang.String channelName, Message<?> requestMessage)
asyncSendAndReceive in interface AsyncMessagingOperationspublic <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.Object request)
asyncConvertSendAndReceive in interface AsyncMessagingOperationspublic <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(MessageChannel channel, java.lang.Object request)
asyncConvertSendAndReceive in interface AsyncMessagingOperationspublic <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.String channelName,
java.lang.Object request)
asyncConvertSendAndReceive in interface AsyncMessagingOperationspublic <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.Object request,
MessagePostProcessor requestPostProcessor)
asyncConvertSendAndReceive in interface AsyncMessagingOperationspublic <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(MessageChannel channel, java.lang.Object request, MessagePostProcessor requestPostProcessor)
asyncConvertSendAndReceive in interface AsyncMessagingOperationspublic <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.String channelName,
java.lang.Object request,
MessagePostProcessor requestPostProcessor)
asyncConvertSendAndReceive in interface AsyncMessagingOperations