com.consol.citrus.actions

Class PurgeMessageChannelAction

java.lang.Object

com.consol.citrus.actions.AbstractTestAction

com.consol.citrus.actions.PurgeMessageChannelAction

All Implemented Interfaces:

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

public class PurgeMessageChannelAction
extends AbstractTestAction
implements org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.BeanFactoryAware

Action purges all messages from a message channel instance. Message channel must be of type QueueChannel. Action receives a list of channel objects or a list of channel names that are resolved dynamically at runtime.

Author:

Christoph Deppisch

Field Summary

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

description

Constructor Summary

Constructors

Constructor and Description
PurgeMessageChannelAction() Default constructor.

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	doExecute(TestContext context) Subclasses may add custom execution logic here.
List<String>	getChannelNames() Gets the channelNames.
org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel>	getChannelResolver() Gets the channelResolver.
List<org.springframework.messaging.MessageChannel>	getChannels() Gets the channels.
org.springframework.integration.core.MessageSelector	getMessageSelector() Gets the messageSelector.
protected org.springframework.messaging.MessageChannel	resolveChannelName(String channelName) Resolve the channel by name.
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) Sets the bean factory for channel resolver.
PurgeMessageChannelAction	setChannelNames(List<String> channelNames) Sets the channelNames.
PurgeMessageChannelAction	setChannelResolver(org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel> channelResolver) Sets the channelResolver.
PurgeMessageChannelAction	setChannels(List<org.springframework.messaging.MessageChannel> channels) Sets the channels.
PurgeMessageChannelAction	setMessageSelector(org.springframework.integration.core.MessageSelector messageSelector) Sets the messageSelector.

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

PurgeMessageChannelAction

public PurgeMessageChannelAction()

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

resolveChannelName

protected org.springframework.messaging.MessageChannel resolveChannelName(String channelName)

Resolve the channel by name.

Parameters:

channelName - the name to resolve

Returns:

the MessageChannel object

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

setBeanFactory

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

Sets the bean factory for channel resolver.

Specified by:

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

Throws:

org.springframework.beans.BeansException

See Also:

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

getChannelNames

public List<String> getChannelNames()

Gets the channelNames.

Returns:

the channelNames the channelNames to get.

setChannelNames

public PurgeMessageChannelAction setChannelNames(List<String> channelNames)

Sets the channelNames.

Parameters:

channelNames - the channelNames to set

getChannels

public List<org.springframework.messaging.MessageChannel> getChannels()

Gets the channels.

Returns:

the channels the channels to get.

setChannels

public PurgeMessageChannelAction setChannels(List<org.springframework.messaging.MessageChannel> channels)

Sets the channels.

Parameters:

channels - the channels to set

getMessageSelector

public org.springframework.integration.core.MessageSelector getMessageSelector()

Gets the messageSelector.

Returns:

the messageSelector the messageSelector to get.

setMessageSelector

public PurgeMessageChannelAction setMessageSelector(org.springframework.integration.core.MessageSelector messageSelector)

Sets the messageSelector.

Parameters:

messageSelector - the messageSelector to set

getChannelResolver

public org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel> getChannelResolver()

Gets the channelResolver.

Returns:

the channelResolver the channelResolver to get.

setChannelResolver

public PurgeMessageChannelAction setChannelResolver(org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel> channelResolver)

Sets the channelResolver.

Parameters:

channelResolver - the channelResolver to set