public class ChannelConsumer extends AbstractSelectiveMessageConsumer
Constructor and Description |
---|
ChannelConsumer(String name,
ChannelEndpointConfiguration endpointConfiguration)
Default constructor using endpoint configuration.
|
Modifier and Type | Method and Description |
---|---|
protected org.springframework.messaging.MessageChannel |
getDestinationChannel()
Get the destination channel depending on settings in this message sender.
|
protected String |
getDestinationChannelName()
Gets the channel name depending on what is set in this message sender.
|
Message |
receive(String selector,
TestContext context,
long timeout)
Receive message with a message selector and a receive timeout.
|
protected org.springframework.messaging.MessageChannel |
resolveChannelName(String channelName)
Resolve the channel by name.
|
receive, receive
getName, receive
public ChannelConsumer(String name, ChannelEndpointConfiguration endpointConfiguration)
name
- endpointConfiguration
- public Message receive(String selector, TestContext context, long timeout)
SelectiveConsumer
timeout
- @returnprotected org.springframework.messaging.MessageChannel getDestinationChannel()
protected String getDestinationChannelName()
protected org.springframework.messaging.MessageChannel resolveChannelName(String channelName)
channelName
- the name to resolveCopyright © 2008–2017 ConSol Software GmbH. All rights reserved.