com.consol.citrus.messaging

Class AbstractSelectiveMessageConsumer

java.lang.Object

com.consol.citrus.messaging.AbstractMessageConsumer

com.consol.citrus.messaging.AbstractSelectiveMessageConsumer

All Implemented Interfaces:

Consumer, SelectiveConsumer

Direct Known Subclasses:

ChannelConsumer

public abstract class AbstractSelectiveMessageConsumer
extends AbstractMessageConsumer
implements SelectiveConsumer

Since:

1.4

Author:

Christoph Deppisch

Constructor Summary

Constructors

Constructor and Description
AbstractSelectiveMessageConsumer(String name, EndpointConfiguration endpointConfiguration) Default constructor using receive timeout setting.

Method Summary

Modifier and Type	Method and Description
Message	receive(String selector, TestContext context) Receive message with a message selector and default timeout.
Message	receive(TestContext context, long timeout) Receive message with a given timeout.

Methods inherited from class com.consol.citrus.messaging.AbstractMessageConsumer

getName, receive

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.consol.citrus.messaging.SelectiveConsumer

receive

Methods inherited from interface com.consol.citrus.messaging.Consumer

getName, receive

Constructor Detail

AbstractSelectiveMessageConsumer

public AbstractSelectiveMessageConsumer(String name,
                                        EndpointConfiguration endpointConfiguration)

Default constructor using receive timeout setting.

Parameters:

name -

endpointConfiguration -

Method Detail

receive

public Message receive(String selector,
                       TestContext context)

Description copied from interface: SelectiveConsumer

Receive message with a message selector and default timeout.

Specified by:

receive in interface SelectiveConsumer

Returns:

receive

public Message receive(TestContext context,
                       long timeout)

Description copied from interface: Consumer

Receive message with a given timeout.

Specified by:

receive in interface Consumer

Returns: