com.consol.citrus.channel

Class ChannelEndpointAdapter

java.lang.Object

com.consol.citrus.endpoint.AbstractEndpointAdapter

com.consol.citrus.channel.ChannelEndpointAdapter

All Implemented Interfaces:

EndpointAdapter, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware

public class ChannelEndpointAdapter
extends AbstractEndpointAdapter
implements org.springframework.beans.factory.BeanFactoryAware

Endpoint adapter forwards incoming requests to message channel and waits synchronously for response on reply channel. Provides channel endpoint for clients to connect to message channel in order to provide proper response message.

Since:

1.4

Author:

Christoph Deppisch

Constructor Summary

Constructors

Constructor and Description
ChannelEndpointAdapter(ChannelSyncEndpointConfiguration endpointConfiguration) Default constructor using endpoint configuration.

Method Summary

Modifier and Type	Method and Description
ChannelEndpoint	getEndpoint() Gets message endpoint to interact with tis endpoint adapter.
ChannelSyncEndpointConfiguration	getEndpointConfiguration() Gets the endpoint configuration.
Message	handleMessageInternal(Message request) Subclasses must implement this method in order to handle incoming request message.
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)

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

afterPropertiesSet, getFallbackEndpointAdapter, getName, getTestContext, getTestContextFactory, handleMessage, setApplicationContext, setBeanName, setFallbackEndpointAdapter, setTestContextFactory

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelEndpointAdapter

public ChannelEndpointAdapter(ChannelSyncEndpointConfiguration endpointConfiguration)

Default constructor using endpoint configuration.

Parameters:

endpointConfiguration -

Method Detail

handleMessageInternal

public Message handleMessageInternal(Message request)

Description copied from class: AbstractEndpointAdapter

Subclasses must implement this method in order to handle incoming request message. If this method does not return any response message fallback endpoint adapter is invoked for processing.

Specified by:

handleMessageInternal in class AbstractEndpointAdapter

Returns:

getEndpoint

public ChannelEndpoint getEndpoint()

Description copied from interface: EndpointAdapter

Gets message endpoint to interact with tis endpoint adapter.

Specified by:

getEndpoint in interface EndpointAdapter

Returns:

getEndpointConfiguration

public ChannelSyncEndpointConfiguration getEndpointConfiguration()

Description copied from interface: EndpointAdapter

Gets the endpoint configuration.

Specified by:

getEndpointConfiguration in interface EndpointAdapter

Returns:

setBeanFactory

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

Specified by:

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

Throws:

org.springframework.beans.BeansException