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, setThrowExceptionOnLateReply
doReceive, doSend, doSendAndReceive, getReceiveTimeout, getSendTimeout, setReceiveTimeout, setSendTimeout
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, getDestinationResolver, receive, receiveAndConvert, resolveDestination, send, sendAndReceive, setDestinationResolver
convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceive
doConvert, receive, receive, receiveAndConvert, receiveAndConvert
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, doConvert, getDefaultDestination, getMessageConverter, getRequiredDefaultDestination, processHeadersToSend, send, send, setDefaultDestination, setMessageConverter
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, send, send
public void setExecutor(Executor executor)
public Future<?> asyncSend(org.springframework.messaging.Message<?> message)
asyncSend
in interface AsyncMessagingOperations
public Future<?> asyncSend(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> message)
asyncSend
in interface AsyncMessagingOperations
public Future<?> asyncSend(String channelName, org.springframework.messaging.Message<?> message)
asyncSend
in interface AsyncMessagingOperations
public Future<?> asyncConvertAndSend(Object object)
asyncConvertAndSend
in interface AsyncMessagingOperations
public Future<?> asyncConvertAndSend(org.springframework.messaging.MessageChannel channel, Object object)
asyncConvertAndSend
in interface AsyncMessagingOperations
public Future<?> asyncConvertAndSend(String channelName, Object object)
asyncConvertAndSend
in interface AsyncMessagingOperations
public Future<org.springframework.messaging.Message<?>> asyncReceive()
asyncReceive
in interface AsyncMessagingOperations
public Future<org.springframework.messaging.Message<?>> asyncReceive(org.springframework.messaging.PollableChannel channel)
asyncReceive
in interface AsyncMessagingOperations
public Future<org.springframework.messaging.Message<?>> asyncReceive(String channelName)
asyncReceive
in interface AsyncMessagingOperations
public <R> Future<R> asyncReceiveAndConvert()
asyncReceiveAndConvert
in interface AsyncMessagingOperations
public <R> Future<R> asyncReceiveAndConvert(org.springframework.messaging.PollableChannel channel)
asyncReceiveAndConvert
in interface AsyncMessagingOperations
public <R> Future<R> asyncReceiveAndConvert(String channelName)
asyncReceiveAndConvert
in interface AsyncMessagingOperations
public Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(org.springframework.messaging.Message<?> requestMessage)
asyncSendAndReceive
in interface AsyncMessagingOperations
public Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> requestMessage)
asyncSendAndReceive
in interface AsyncMessagingOperations
public Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(String channelName, org.springframework.messaging.Message<?> requestMessage)
asyncSendAndReceive
in interface AsyncMessagingOperations
public <R> Future<R> asyncConvertSendAndReceive(Object request)
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
public <R> Future<R> asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, Object request)
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
public <R> Future<R> asyncConvertSendAndReceive(String channelName, Object request)
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
public <R> Future<R> asyncConvertSendAndReceive(Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
public <R> Future<R> asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
public <R> Future<R> asyncConvertSendAndReceive(String channelName, Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)
asyncConvertSendAndReceive
in interface AsyncMessagingOperations