public class ChannelSyncProducer extends ChannelProducer implements ReplyConsumer
Constructor and Description |
---|
ChannelSyncProducer(String name,
ChannelSyncEndpointConfiguration endpointConfiguration)
Default constructor using endpoint configuration.
|
Modifier and Type | Method and Description |
---|---|
CorrelationManager<Message> |
getCorrelationManager()
Gets the correlation manager.
|
Message |
receive(String selector,
TestContext context)
Receive message with a message selector and default timeout.
|
Message |
receive(String selector,
TestContext context,
long timeout)
Receive message with a message selector and a receive timeout.
|
Message |
receive(TestContext context)
Receive message with default timeout.
|
Message |
receive(TestContext context,
long timeout)
Receive message with a given timeout.
|
void |
send(Message message,
TestContext context)
Sends the message.
|
void |
setCorrelationManager(CorrelationManager<Message> correlationManager)
Sets the correlation manager.
|
getDestinationChannel, getDestinationChannelName, getName, resolveChannelName
public ChannelSyncProducer(String name, ChannelSyncEndpointConfiguration endpointConfiguration)
name
- endpointConfiguration
- public void send(Message message, TestContext context)
Producer
send
in interface Producer
send
in class ChannelProducer
message
- the message object to send.public Message receive(TestContext context)
Consumer
public Message receive(String selector, TestContext context)
SelectiveConsumer
receive
in interface SelectiveConsumer
public Message receive(TestContext context, long timeout)
Consumer
public Message receive(String selector, TestContext context, long timeout)
SelectiveConsumer
receive
in interface SelectiveConsumer
timeout
- @returnpublic CorrelationManager<Message> getCorrelationManager()
public void setCorrelationManager(CorrelationManager<Message> correlationManager)
correlationManager
- Copyright © 2008–2017 ConSol Software GmbH. All rights reserved.