com.consol.citrus.actions

Class PurgeEndpointAction

java.lang.Object

com.consol.citrus.actions.AbstractTestAction

com.consol.citrus.actions.PurgeEndpointAction

All Implemented Interfaces:

TestAction, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware

public class PurgeEndpointAction
extends AbstractTestAction
implements org.springframework.beans.factory.BeanFactoryAware

Action purges all messages from a message endpoint. Action receives a list of endpoint objects or a list of endpoint names that are resolved dynamically at runtime.

Since:

2.4

Author:

Christoph Deppisch

Field Summary

Fields inherited from class com.consol.citrus.actions.AbstractTestAction

description

Constructor Summary

Constructors

Constructor and Description
PurgeEndpointAction() Default constructor.

Method Summary

Modifier and Type	Method and Description
void	doExecute(TestContext context) Subclasses may add custom execution logic here.
org.springframework.beans.factory.BeanFactory	getBeanFactory() Gets the bean factory for endpoint name resolving.
List<String>	getEndpointNames() Gets the endpointNames.
List<Endpoint>	getEndpoints() Gets the endpoints.
Map<String,Object>	getMessageSelector() Gets the messageSelector.
String	getMessageSelectorString() Gets the messageSelectorString.
long	getReceiveTimeout() Gets the receiveTimeout.
long	getSleepTime() Gets the sleepTime.
protected Endpoint	resolveEndpointName(String endpointName) Resolve the endpoint by name.
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) Sets the bean factory for endpoint name resolving.
PurgeEndpointAction	setEndpointNames(List<String> endpointNames) Sets the endpointNames.
PurgeEndpointAction	setEndpoints(List<Endpoint> endpoints) Sets the endpoints.
PurgeEndpointAction	setMessageSelector(Map<String,Object> messageSelector) Setter for messageSelector.
PurgeEndpointAction	setMessageSelectorString(String messageSelectorString) Set message selector string.
PurgeEndpointAction	setReceiveTimeout(long receiveTimeout) Set the receive timeout.
void	setSleepTime(long sleepTime) Sets the sleepTime.

Methods inherited from class com.consol.citrus.actions.AbstractTestAction

execute, getActor, getDescription, getName, isDisabled, setActor, setDescription, setName

Methods inherited from class java.lang.Object

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

Constructor Detail

PurgeEndpointAction

public PurgeEndpointAction()

Default constructor.

Method Detail

doExecute

public void doExecute(TestContext context)

Description copied from class: AbstractTestAction

Subclasses may add custom execution logic here.

Specified by:

doExecute in class AbstractTestAction

resolveEndpointName

protected Endpoint resolveEndpointName(String endpointName)

Resolve the endpoint by name.

Parameters:

endpointName - the name to resolve

Returns:

the Endpoint object

setBeanFactory

public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
                    throws org.springframework.beans.BeansException

Sets the bean factory for endpoint name resolving.

Specified by:

setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware

Throws:

org.springframework.beans.BeansException

See Also:

BeanFactoryAware.setBeanFactory(org.springframework.beans.factory.BeanFactory)

getBeanFactory

public org.springframework.beans.factory.BeanFactory getBeanFactory()

Gets the bean factory for endpoint name resolving.

Returns:

getEndpointNames

public List<String> getEndpointNames()

Gets the endpointNames.

Returns:

the endpointNames the endpointNames to get.

setEndpointNames

public PurgeEndpointAction setEndpointNames(List<String> endpointNames)

Sets the endpointNames.

Parameters:

endpointNames - the endpointNames to set

getEndpoints

public List<Endpoint> getEndpoints()

Gets the endpoints.

Returns:

the endpoints the endpoints to get.

setEndpoints

public PurgeEndpointAction setEndpoints(List<Endpoint> endpoints)

Sets the endpoints.

Parameters:

endpoints - the endpoints to set

setMessageSelector

public PurgeEndpointAction setMessageSelector(Map<String,Object> messageSelector)

Setter for messageSelector.

Parameters:

messageSelector -

setMessageSelectorString

public PurgeEndpointAction setMessageSelectorString(String messageSelectorString)

Set message selector string.

Parameters:

messageSelectorString -

getMessageSelector

public Map<String,Object> getMessageSelector()

Gets the messageSelector.

Returns:

the messageSelector

getMessageSelectorString

public String getMessageSelectorString()

Gets the messageSelectorString.

Returns:

the messageSelectorString

getReceiveTimeout

public long getReceiveTimeout()

Gets the receiveTimeout.

Returns:

the receiveTimeout

setReceiveTimeout

public PurgeEndpointAction setReceiveTimeout(long receiveTimeout)

Set the receive timeout.

Parameters:

receiveTimeout - the receiveTimeout to set

setSleepTime

public void setSleepTime(long sleepTime)

Sets the sleepTime.

Parameters:

sleepTime - the sleepTime to set

getSleepTime

public long getSleepTime()

Gets the sleepTime.

Returns:

the sleepTime the sleepTime to get.