public class ChannelSyncConsumer extends ChannelConsumer implements ReplyProducer
Constructor and Description |
---|
ChannelSyncConsumer(String name,
ChannelSyncEndpointConfiguration endpointConfiguration)
Default constructor using emdpoint configuration.
|
Modifier and Type | Method and Description |
---|---|
CorrelationManager<org.springframework.messaging.MessageChannel> |
getCorrelationManager()
Gets the correlation manager.
|
Message |
receive(String selector,
TestContext context,
long timeout)
Receive message with a message selector and a receive timeout.
|
void |
saveReplyMessageChannel(Message receivedMessage,
TestContext context)
Store reply message channel.
|
void |
send(Message message,
TestContext context)
Sends the message.
|
void |
setCorrelationManager(CorrelationManager<org.springframework.messaging.MessageChannel> correlationManager)
Sets the correlation manager.
|
getDestinationChannel, getDestinationChannelName, resolveChannelName
receive, receive
getName, receive
public ChannelSyncConsumer(String name, ChannelSyncEndpointConfiguration endpointConfiguration)
name
- endpointConfiguration
- public Message receive(String selector, TestContext context, long timeout)
SelectiveConsumer
receive
in interface SelectiveConsumer
receive
in class ChannelConsumer
timeout
- @returnpublic void send(Message message, TestContext context)
Producer
public void saveReplyMessageChannel(Message receivedMessage, TestContext context)
receivedMessage
- context
- public CorrelationManager<org.springframework.messaging.MessageChannel> getCorrelationManager()
public void setCorrelationManager(CorrelationManager<org.springframework.messaging.MessageChannel> correlationManager)
correlationManager
- Copyright © 2008–2017 ConSol Software GmbH. All rights reserved.