public class AsyncMessagingTemplate extends MessagingTemplate implements AsyncMessagingOperations
| Constructor and Description |
|---|
AsyncMessagingTemplate() |
| Modifier and Type | Method and Description |
|---|---|
Future<?> |
asyncConvertAndSend(org.springframework.messaging.MessageChannel channel,
Object object) |
Future<?> |
asyncConvertAndSend(Object object) |
Future<?> |
asyncConvertAndSend(String channelName,
Object object) |
<R> Future<R> |
asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel,
Object request) |
<R> Future<R> |
asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel,
Object request,
org.springframework.messaging.core.MessagePostProcessor requestPostProcessor) |
<R> Future<R> |
asyncConvertSendAndReceive(Object request) |
<R> Future<R> |
asyncConvertSendAndReceive(Object request,
org.springframework.messaging.core.MessagePostProcessor requestPostProcessor) |
<R> Future<R> |
asyncConvertSendAndReceive(String channelName,
Object request) |
<R> Future<R> |
asyncConvertSendAndReceive(String channelName,
Object request,
org.springframework.messaging.core.MessagePostProcessor requestPostProcessor) |
Future<org.springframework.messaging.Message<?>> |
asyncReceive() |
Future<org.springframework.messaging.Message<?>> |
asyncReceive(org.springframework.messaging.PollableChannel channel) |
Future<org.springframework.messaging.Message<?>> |
asyncReceive(String channelName) |
<R> Future<R> |
asyncReceiveAndConvert() |
<R> Future<R> |
asyncReceiveAndConvert(org.springframework.messaging.PollableChannel channel) |
<R> Future<R> |
asyncReceiveAndConvert(String channelName) |
Future<?> |
asyncSend(org.springframework.messaging.Message<?> message) |
Future<?> |
asyncSend(org.springframework.messaging.MessageChannel channel,
org.springframework.messaging.Message<?> message) |
Future<?> |
asyncSend(String channelName,
org.springframework.messaging.Message<?> message) |
Future<org.springframework.messaging.Message<?>> |
asyncSendAndReceive(org.springframework.messaging.Message<?> requestMessage) |
Future<org.springframework.messaging.Message<?>> |
asyncSendAndReceive(org.springframework.messaging.MessageChannel channel,
org.springframework.messaging.Message<?> requestMessage) |
Future<org.springframework.messaging.Message<?>> |
asyncSendAndReceive(String channelName,
org.springframework.messaging.Message<?> requestMessage) |
void |
setExecutor(Executor executor) |
sendAndReceive, setBeanFactory, setDefaultChannel, setThrowExceptionOnLateReplydoReceive, doSend, doSendAndReceive, getReceiveTimeout, getSendTimeout, setReceiveTimeout, setSendTimeoutconvertAndSend, convertAndSend, convertAndSend, convertAndSend, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, getDestinationResolver, receive, receiveAndConvert, resolveDestination, send, sendAndReceive, setDestinationResolverconvertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceivedoConvert, receive, receive, receiveAndConvert, receiveAndConvertconvertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, doConvert, getDefaultDestination, getMessageConverter, getRequiredDefaultDestination, processHeadersToSend, send, send, setDefaultDestination, setMessageConverterclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitconvertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, send, sendpublic void setExecutor(Executor executor)
public Future<?> asyncSend(org.springframework.messaging.Message<?> message)
asyncSend in interface AsyncMessagingOperationspublic Future<?> asyncSend(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> message)
asyncSend in interface AsyncMessagingOperationspublic Future<?> asyncSend(String channelName, org.springframework.messaging.Message<?> message)
asyncSend in interface AsyncMessagingOperationspublic Future<?> asyncConvertAndSend(Object object)
asyncConvertAndSend in interface AsyncMessagingOperationspublic Future<?> asyncConvertAndSend(org.springframework.messaging.MessageChannel channel, Object object)
asyncConvertAndSend in interface AsyncMessagingOperationspublic Future<?> asyncConvertAndSend(String channelName, Object object)
asyncConvertAndSend in interface AsyncMessagingOperationspublic Future<org.springframework.messaging.Message<?>> asyncReceive()
asyncReceive in interface AsyncMessagingOperationspublic Future<org.springframework.messaging.Message<?>> asyncReceive(org.springframework.messaging.PollableChannel channel)
asyncReceive in interface AsyncMessagingOperationspublic Future<org.springframework.messaging.Message<?>> asyncReceive(String channelName)
asyncReceive in interface AsyncMessagingOperationspublic <R> Future<R> asyncReceiveAndConvert()
asyncReceiveAndConvert in interface AsyncMessagingOperationspublic <R> Future<R> asyncReceiveAndConvert(org.springframework.messaging.PollableChannel channel)
asyncReceiveAndConvert in interface AsyncMessagingOperationspublic <R> Future<R> asyncReceiveAndConvert(String channelName)
asyncReceiveAndConvert in interface AsyncMessagingOperationspublic Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(org.springframework.messaging.Message<?> requestMessage)
asyncSendAndReceive in interface AsyncMessagingOperationspublic Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> requestMessage)
asyncSendAndReceive in interface AsyncMessagingOperationspublic Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(String channelName, org.springframework.messaging.Message<?> requestMessage)
asyncSendAndReceive in interface AsyncMessagingOperationspublic <R> Future<R> asyncConvertSendAndReceive(Object request)
asyncConvertSendAndReceive in interface AsyncMessagingOperationspublic <R> Future<R> asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, Object request)
asyncConvertSendAndReceive in interface AsyncMessagingOperationspublic <R> Future<R> asyncConvertSendAndReceive(String channelName, Object request)
asyncConvertSendAndReceive in interface AsyncMessagingOperationspublic <R> Future<R> asyncConvertSendAndReceive(Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)
asyncConvertSendAndReceive in interface AsyncMessagingOperationspublic <R> Future<R> asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)
asyncConvertSendAndReceive in interface AsyncMessagingOperationspublic <R> Future<R> asyncConvertSendAndReceive(String channelName, Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)
asyncConvertSendAndReceive in interface AsyncMessagingOperations