org.springframework.integration.core

Interface AsyncMessagingOperations

All Known Implementing Classes:

AsyncMessagingTemplate

public interface AsyncMessagingOperations

Since:

2.0

Author:

Mark Fisher

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.Future<?>	asyncConvertAndSend(org.springframework.messaging.MessageChannel channel, java.lang.Object message)
java.util.concurrent.Future<?>	asyncConvertAndSend(java.lang.Object message)
java.util.concurrent.Future<?>	asyncConvertAndSend(java.lang.String channelName, java.lang.Object message)
<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)

Method Detail

asyncSend

java.util.concurrent.Future<?> asyncSend(org.springframework.messaging.Message<?> message)

asyncSend

java.util.concurrent.Future<?> asyncSend(org.springframework.messaging.MessageChannel channel,
                                         org.springframework.messaging.Message<?> message)

asyncSend

java.util.concurrent.Future<?> asyncSend(java.lang.String channelName,
                                         org.springframework.messaging.Message<?> message)

asyncConvertAndSend

java.util.concurrent.Future<?> asyncConvertAndSend(java.lang.Object message)

asyncConvertAndSend

java.util.concurrent.Future<?> asyncConvertAndSend(org.springframework.messaging.MessageChannel channel,
                                                   java.lang.Object message)

asyncConvertAndSend

java.util.concurrent.Future<?> asyncConvertAndSend(java.lang.String channelName,
                                                   java.lang.Object message)

asyncReceive

java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncReceive()

asyncReceive

java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncReceive(org.springframework.messaging.PollableChannel channel)

asyncReceive

java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncReceive(java.lang.String channelName)

asyncReceiveAndConvert

<R> java.util.concurrent.Future<R> asyncReceiveAndConvert()

asyncReceiveAndConvert

<R> java.util.concurrent.Future<R> asyncReceiveAndConvert(org.springframework.messaging.PollableChannel channel)

asyncReceiveAndConvert

<R> java.util.concurrent.Future<R> asyncReceiveAndConvert(java.lang.String channelName)

asyncSendAndReceive

java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(org.springframework.messaging.Message<?> requestMessage)

asyncSendAndReceive

java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(org.springframework.messaging.MessageChannel channel,
                                                                                          org.springframework.messaging.Message<?> requestMessage)

asyncSendAndReceive

java.util.concurrent.Future<org.springframework.messaging.Message<?>> asyncSendAndReceive(java.lang.String channelName,
                                                                                          org.springframework.messaging.Message<?> requestMessage)

asyncConvertSendAndReceive

<R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.Object request)

asyncConvertSendAndReceive

<R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel,
                                                              java.lang.Object request)

asyncConvertSendAndReceive

<R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.String channelName,
                                                              java.lang.Object request)

asyncConvertSendAndReceive

<R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.Object request,
                                                              org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)

asyncConvertSendAndReceive

<R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(org.springframework.messaging.MessageChannel channel,
                                                              java.lang.Object request,
                                                              org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)

asyncConvertSendAndReceive

<R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(java.lang.String channelName,
                                                              java.lang.Object request,
                                                              org.springframework.messaging.core.MessagePostProcessor requestPostProcessor)