org.springframework.integration.core

Interface AsyncMessagingOperations

All Known Implementing Classes:

AsyncMessagingTemplate

public interface AsyncMessagingOperations

Since:

2.0

Author:

Mark Fisher

Method Summary

Methods

Modifier and Type	Method and Description
java.util.concurrent.Future<?>	asyncConvertAndSend(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(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)

Method Detail

asyncSend

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

asyncSend

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

asyncSend

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

asyncConvertAndSend

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

asyncConvertAndSend

java.util.concurrent.Future<?> asyncConvertAndSend(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<Message<?>> asyncReceive()

asyncReceive

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

asyncReceive

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

asyncReceiveAndConvert

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

asyncReceiveAndConvert

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

asyncReceiveAndConvert

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

asyncSendAndReceive

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

asyncSendAndReceive

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

asyncSendAndReceive

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

asyncConvertSendAndReceive

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

asyncConvertSendAndReceive

<R> java.util.concurrent.Future<R> asyncConvertSendAndReceive(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,
                                                            MessagePostProcessor requestPostProcessor)

asyncConvertSendAndReceive

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

asyncConvertSendAndReceive

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