|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.springframework.integration.gateway.RequestReplyTemplate
public class RequestReplyTemplate
A template that facilitates the implementation of request-reply usage
scenarios above one-way MessageChannels
.
Nested Class Summary | |
---|---|
private static class |
RequestReplyTemplate.ReplyHandlingChannelAdapter
|
Field Summary | |
---|---|
private EndpointRegistry |
endpointRegistry
|
private MessageChannel |
replyChannel
|
private ReplyMessageCorrelator |
replyMessageCorrelator
|
private java.lang.Object |
replyMessageCorrelatorMonitor
|
private long |
replyTimeout
|
private MessageChannel |
requestChannel
|
private long |
requestTimeout
|
Constructor Summary | |
---|---|
RequestReplyTemplate()
|
|
RequestReplyTemplate(MessageChannel requestChannel)
Create a RequestReplyTemplate that will use anonymous temporary channels for replies. |
|
RequestReplyTemplate(MessageChannel requestChannel,
MessageChannel replyChannel)
Create a RequestReplyTemplate. |
Method Summary | |
---|---|
Message<?> |
receive()
|
private Message<?> |
receiveResponse(MessageChannel channel)
|
private void |
registerReplyMessageCorrelator()
|
Message<?> |
request(Message<?> message)
Send a request message and wait for a reply message using the configured timeout values. |
boolean |
request(Message<?> message,
ReplyHandler replyHandler)
Send a request message whose reply should be handled be the provided callback. |
boolean |
send(Message<?> message)
|
private Message<?> |
sendAndReceiveWithReplyMessageCorrelator(Message<?> message)
|
private Message<?> |
sendAndReceiveWithTemporaryChannel(Message<?> message)
|
void |
setEndpointRegistry(EndpointRegistry endpointRegistry)
|
void |
setMessageBus(MessageBus messageBus)
|
void |
setReplyChannel(MessageChannel replyChannel)
Set the reply channel. |
void |
setReplyTimeout(long replyTimeout)
Set the timeout value for receiving reply messages. |
void |
setRequestChannel(MessageChannel requestChannel)
Set the request channel. |
void |
setRequestTimeout(long requestTimeout)
Set the timeout value for sending request messages. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private MessageChannel requestChannel
private MessageChannel replyChannel
private volatile long requestTimeout
private volatile long replyTimeout
private ReplyMessageCorrelator replyMessageCorrelator
private EndpointRegistry endpointRegistry
private final java.lang.Object replyMessageCorrelatorMonitor
Constructor Detail |
---|
public RequestReplyTemplate(MessageChannel requestChannel, MessageChannel replyChannel)
requestChannel
- the channel to which request messages will be sentreplyChannel
- the channel from which reply messages will be receivedpublic RequestReplyTemplate(MessageChannel requestChannel)
requestChannel
- the channel to which request messages will be sentpublic RequestReplyTemplate()
Method Detail |
---|
public void setRequestChannel(MessageChannel requestChannel)
requestChannel
- the channel to which request messages will be sentpublic void setReplyChannel(MessageChannel replyChannel)
replyChannel
- the channel from which reply messages will be receivedpublic void setRequestTimeout(long requestTimeout)
requestTimeout
- the timeout value in millisecondspublic void setReplyTimeout(long replyTimeout)
replyTimeout
- the timeout value in millisecondspublic void setEndpointRegistry(EndpointRegistry endpointRegistry)
public void setMessageBus(MessageBus messageBus)
setMessageBus
in interface MessageBusAware
public boolean send(Message<?> message)
public Message<?> receive()
public boolean request(Message<?> message, ReplyHandler replyHandler)
public Message<?> request(Message<?> message)
requestMessage
- the request message to send
null
private Message<?> sendAndReceiveWithReplyMessageCorrelator(Message<?> message)
private Message<?> sendAndReceiveWithTemporaryChannel(Message<?> message)
private Message<?> receiveResponse(MessageChannel channel)
private void registerReplyMessageCorrelator()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |