Package org.citrusframework.message

Class DefaultMessageQueue

java.lang.Object

org.citrusframework.message.DefaultMessageQueue

All Implemented Interfaces:

org.citrusframework.message.MessageQueue

public class DefaultMessageQueue
extends Object
implements org.citrusframework.message.MessageQueue

Default message queue implementation. Holds queued messages in memory and adds selective consumption of messages according to a message selector implementation.

Constructor Summary

Constructors

Constructor	Description
DefaultMessageQueue(String name)

Method Summary

Modifier and Type	Method	Description
String	getName()
long	getPollingInterval()	Gets the pollingInterval.
boolean	isLoggingEnabled()	Obtains the loggingEnabled.
void	purge(org.citrusframework.message.MessageSelector selector)
org.citrusframework.message.Message	receive(org.citrusframework.message.MessageSelector selector)
org.citrusframework.message.Message	receive(org.citrusframework.message.MessageSelector selector, long timeout)
void	send(org.citrusframework.message.Message message)
void	setLoggingEnabled(boolean loggingEnabled)	Specifies the loggingEnabled.
void	setPollingInterval(long pollingInterval)	Sets the pollingInterval.
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.citrusframework.message.MessageQueue

receive, receive

Constructor Details

DefaultMessageQueue

public DefaultMessageQueue(String name)

Method Details

send

public void send(org.citrusframework.message.Message message)

Specified by:

send in interface org.citrusframework.message.MessageQueue

receive

public org.citrusframework.message.Message receive(org.citrusframework.message.MessageSelector selector)

Specified by:

receive in interface org.citrusframework.message.MessageQueue

receive

public org.citrusframework.message.Message receive(org.citrusframework.message.MessageSelector selector,
 long timeout)

Specified by:

receive in interface org.citrusframework.message.MessageQueue

purge

public void purge(org.citrusframework.message.MessageSelector selector)

Specified by:

purge in interface org.citrusframework.message.MessageQueue

getPollingInterval

public long getPollingInterval()

Gets the pollingInterval.

Returns:

the pollingInterval to get.

setPollingInterval

public void setPollingInterval(long pollingInterval)

Sets the pollingInterval.

Parameters:

pollingInterval - the pollingInterval to set

isLoggingEnabled

public boolean isLoggingEnabled()

Obtains the loggingEnabled.

setLoggingEnabled

public void setLoggingEnabled(boolean loggingEnabled)

Specifies the loggingEnabled.

getName

public String getName()

Specified by:

getName in interface org.citrusframework.message.MessageQueue

toString

public String toString()

Overrides:

toString in class Object