public class AsyncMessagingTemplate extends MessagingTemplate implements AsyncMessagingOperations
Constructor and Description |
---|
AsyncMessagingTemplate() |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<?> |
asyncConvertAndSend(org.springframework.messaging.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(org.springframework.messaging.MessageChannel channel,
java.lang.Object request) |
<R> java.util.concurrent.Future<R> |
asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel,
java.lang.Object request,
org.springframework.messaging.core.MessagePostProcessor requestPostProcessor) |
<R> java.util.concurrent.Future<R> |
asyncConvertSendAndReceive(java.lang.Object request) |
<R> java.util.concurrent.Future<R> |
asyncConvertSendAndReceive(java.lang.Object request,
org.springframework.messaging.core.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,
org.springframework.messaging.core.MessagePostProcessor requestPostProcessor) |
java.util.concurrent.Future<org.springframework.messaging.Message<?>> |
asyncReceive() |
java.util.concurrent.Future<org.springframework.messaging.Message<?>> |
asyncReceive(org.springframework.messaging.PollableChannel channel) |
java.util.concurrent.Future<org.springframework.messaging.Message<?>> |
asyncReceive(java.lang.String channelName) |
<R> java.util.concurrent.Future<R> |
asyncReceiveAndConvert() |
<R> java.util.concurrent.Future<R> |
asyncReceiveAndConvert(org.springframework.messaging.PollableChannel channel) |
<R> java.util.concurrent.Future<R> |
asyncReceiveAndConvert(java.lang.String channelName) |
java.util.concurrent.Future<?> |
asyncSend(org.springframework.messaging.Message<?> message) |
java.util.concurrent.Future<?> |
asyncSend(org.springframework.messaging.MessageChannel channel,
org.springframework.messaging.Message<?> message) |
java.util.concurrent.Future<?> |
asyncSend(java.lang.String channelName,
org.springframework.messaging.Message<?> message) |
java.util.concurrent.Future<org.springframework.messaging.Message<?>> |
asyncSendAndReceive(org.springframework.messaging.Message<?> requestMessage) |
java.util.concurrent.Future<org.springframework.messaging.Message<?>> |
asyncSendAndReceive(org.springframework.messaging.MessageChannel channel,
org.springframework.messaging.Message<?> requestMessage) |
java.util.concurrent.Future<org.springframework.messaging.Message<?>> |
asyncSendAndReceive(java.lang.String channelName,
org.springframework.messaging.Message<?> requestMessage) |
void |
setExecutor(java.util.concurrent.Executor executor) |
receive, receiveAndConvert, sendAndReceive, setBeanFactory, setDefaultChannel, setThrowExceptionOnLateReply
doReceive, doReceive, doSend, doSend, doSendAndReceive, getReceiveTimeout, getReceiveTimeoutHeader, getSendTimeout, getSendTimeoutHeader, setReceiveTimeout, setReceiveTimeoutHeader, setSendTimeout, setSendTimeoutHeader
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(java.util.concurrent.Executor executor)
public java.util.concurrent.Future<?> asyncSend(org.springframework.messaging.Message<?> message)
asyncSend
in interface AsyncMessagingOperations
public java.util.concurrent.Future<?> asyncSend(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> message)
asyncSend
in interface AsyncMessagingOperations
public java.util.concurrent.Future<?> asyncSend(java.lang.String channelName, org.springframework.messaging.Message<?> message)
asyncSend
in interface AsyncMessagingOperations
public java.util.concurrent.Future<?> asyncConvertAndSend(java.lang.Object object)
asyncConvertAndSend
in interface AsyncMessagingOperations
public java.util.concurrent.Future<?> asyncConvertAndSend(org.springframework.messaging.MessageChannel channel, java.lang.Object object)
asyncConvertAndSend
in interface AsyncMessagingOperations
public java.util.concurrent.Future<?> asyncConvertAndSend(java.lang.String channelName, java.lang.Object object)
asyncConvertAndSend
in interface AsyncMessagingOperations
public java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncReceive()
asyncReceive
in interface AsyncMessagingOperations
public java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncReceive(org.springframework.messaging.PollableChannel channel)
asyncReceive
in interface AsyncMessagingOperations
public java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncReceive(java.lang.String channelName)
asyncReceive
in interface AsyncMessagingOperations
public <R> java.util.concurrent.Future<R> asyncReceiveAndConvert()
asyncReceiveAndConvert
in interface AsyncMessagingOperations
public <R> java.util.concurrent.Future<R> asyncReceiveAndConvert(org.springframework.messaging.PollableChannel channel)
asyncReceiveAndConvert
in interface AsyncMessagingOperations
public <R> java.util.concurrent.Future<R> asyncReceiveAndConvert(java.lang.String channelName)
asyncReceiveAndConvert
in interface AsyncMessagingOperations
public java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(org.springframework.messaging.Message<?> requestMessage)
asyncSendAndReceive
in interface AsyncMessagingOperations
public java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(org.springframework.messaging.MessageChannel channel, org.springframework.messaging.Message<?> requestMessage)
asyncSendAndReceive
in interface AsyncMessagingOperations
public java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(java.lang.String channelName, org.springframework.messaging.Message<?> requestMessage)
asyncSendAndReceive
in interface AsyncMessagingOperations
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.Object request)
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, java.lang.Object request)
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.String channelName, java.lang.Object request)
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel, java.lang.Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)
asyncConvertSendAndReceive
in interface AsyncMessagingOperations
public <R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.String channelName, java.lang.Object request, org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)
asyncConvertSendAndReceive
in interface AsyncMessagingOperations