com.consol.citrus.channel

Class ChannelEndpoint

java.lang.Object

com.consol.citrus.endpoint.AbstractEndpoint

com.consol.citrus.channel.ChannelEndpoint

All Implemented Interfaces:

Endpoint, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware

Direct Known Subclasses:

ChannelSyncEndpoint

public class ChannelEndpoint
extends AbstractEndpoint
implements org.springframework.beans.factory.BeanFactoryAware

Basic message endpoint sends and receives message from Spring message channel. When receiving messages channel must implement PollableChannel interface. When using message selector channel must be of type MessageSelectingQueueChannel.

Since:

1.4

Author:

Christoph Deppisch

Constructor Summary

Constructors

Constructor and Description
ChannelEndpoint() Default constructor initializing endpoint configuration.
ChannelEndpoint(ChannelEndpointConfiguration endpointConfiguration) Constructor with endpoint configuration.

Method Summary

Modifier and Type	Method and Description
SelectiveConsumer	createConsumer() Creates a message consumer for this endpoint.
Producer	createProducer() Creates a message producer for this endpoint for sending messages to this endpoint.
ChannelEndpointConfiguration	getEndpointConfiguration() Gets the endpoint configuration holding all endpoint specific properties such as endpoint uri, connection timeout, ports, etc.
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) Sets the bean factory for channel resolver.

Methods inherited from class com.consol.citrus.endpoint.AbstractEndpoint

getActor, getConsumerName, getName, getProducerName, setActor, setBeanName, setName

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelEndpoint

public ChannelEndpoint()

Default constructor initializing endpoint configuration.

ChannelEndpoint

public ChannelEndpoint(ChannelEndpointConfiguration endpointConfiguration)

Constructor with endpoint configuration.

Parameters:

endpointConfiguration -

Method Detail

createConsumer

public SelectiveConsumer createConsumer()

Description copied from interface: Endpoint

Creates a message consumer for this endpoint. Consumer receives messages on this endpoint.

Specified by:

createConsumer in interface Endpoint

Returns:

createProducer

public Producer createProducer()

Description copied from interface: Endpoint

Creates a message producer for this endpoint for sending messages to this endpoint.

Specified by:

createProducer in interface Endpoint

getEndpointConfiguration

public ChannelEndpointConfiguration getEndpointConfiguration()

Description copied from interface: Endpoint

Gets the endpoint configuration holding all endpoint specific properties such as endpoint uri, connection timeout, ports, etc.

Specified by:

getEndpointConfiguration in interface Endpoint

Overrides:

getEndpointConfiguration in class AbstractEndpoint

Returns:

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)