org.milyn.smooks.camel.routing

Class BeanRouter

java.lang.Object

org.milyn.smooks.camel.routing.BeanRouter

All Implemented Interfaces:

ContentHandler, ExecutionLifecycleCleanable, ExecutionLifecycleInitializable, Consumer, SAXVisitAfter, SAXVisitor, Visitor

public class BeanRouter
extends Object
implements SAXVisitAfter, Consumer, ExecutionLifecycleInitializable, ExecutionLifecycleCleanable

Camel bean routing visitor.

Author:

tom.fennelly@gmail.com, daniel.bevenius@gmail.com

Constructor Summary

Constructors

Constructor and Description
BeanRouter()
BeanRouter(org.apache.camel.CamelContext camelContext)

Method Summary

Modifier and Type	Method and Description
boolean	consumes(Object object) Does this consumer consume the specified named object.
void	executeExecutionLifecycleCleanup(ExecutionContext executionContext) Cleanup the resources allocated by this resource for the specified ExecutionContext.
void	executeExecutionLifecycleInitialize(ExecutionContext executionContext) Initialize the resources allocated by this resource for the specified ExecutionContext.
void	initialize()
protected void	sendBean(Object bean, ExecutionContext execContext) Send the bean to the target endpoint.
BeanRouter	setBeanId(String beanId) Set the beanId of the bean to be routed.
BeanRouter	setCorrelationIdName(String correlationIdName) Set the correlationId header name.
BeanRouter	setCorrelationIdPattern(String correlationIdPattern) Set the correlationId pattern used to generate correlationIds.
BeanRouter	setToEndpoint(String toEndpoint) Set the Camel endpoint to which the bean is to be routed.
void	uninitialize()
void	visitAfter(SAXElement element, ExecutionContext execContext) Visit the supplied element after visiting its child elements.

Methods inherited from class java.lang.Object

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

Constructor Detail

BeanRouter

public BeanRouter()

BeanRouter

public BeanRouter(org.apache.camel.CamelContext camelContext)

Method Detail

initialize

@Initialize
public void initialize()

setBeanId

public BeanRouter setBeanId(String beanId)

Set the beanId of the bean to be routed.

Parameters:

beanId - the beanId to set

Returns:

This router instance.

setToEndpoint

public BeanRouter setToEndpoint(String toEndpoint)

Set the Camel endpoint to which the bean is to be routed.

Parameters:

toEndpoint - the toEndpoint to set

Returns:

This router instance.

setCorrelationIdName

public BeanRouter setCorrelationIdName(String correlationIdName)

Set the correlationId header name.

Returns:

This router instance.

setCorrelationIdPattern

public BeanRouter setCorrelationIdPattern(String correlationIdPattern)

Set the correlationId pattern used to generate correlationIds.

Parameters:

correlationIdPattern - The pattern generator template.

Returns:

This router instance.

visitAfter

public void visitAfter(SAXElement element,
                       ExecutionContext execContext)
                throws SmooksException,
                       IOException

Description copied from interface: SAXVisitAfter

Visit the supplied element after visiting its child elements.

Specified by:

visitAfter in interface SAXVisitAfter

Parameters:

element - The SAX element being visited.

execContext - Execution context.

Throws:

SmooksException - Event processing failure.

IOException - Error writing event to output writer.

sendBean

protected void sendBean(Object bean,
                        ExecutionContext execContext)

Send the bean to the target endpoint.

Parameters:

bean - The bean to be sent.

execContext - The execution context.

uninitialize

@Uninitialize
public void uninitialize()

consumes

public boolean consumes(Object object)

Description copied from interface: Consumer

Does this consumer consume the specified named object.

The named object would be a product of a Producer that is executing on the same element. The consumer should only return false if it knows for certain that it doesn't consumer the specified named object. If uncertain, it should error on the side of saying that it does consume the object.

Specified by:

consumes in interface Consumer

Parameters:

object - The product representation

Returns:

True if the consumer consumes the specified product, otherwise false.

executeExecutionLifecycleInitialize

public void executeExecutionLifecycleInitialize(ExecutionContext executionContext)

Description copied from interface: ExecutionLifecycleInitializable

Initialize the resources allocated by this resource for the specified ExecutionContext.

Executes the initialization at the start of the filter execution.

Specified by:

executeExecutionLifecycleInitialize in interface ExecutionLifecycleInitializable

Parameters:

executionContext - The ExecutionContext.

executeExecutionLifecycleCleanup

public void executeExecutionLifecycleCleanup(ExecutionContext executionContext)

Description copied from interface: ExecutionLifecycleCleanable

Cleanup the resources allocated by this resource for the specified ExecutionContext.

Executes the cleanup at the end of the filter execution.

Specified by:

executeExecutionLifecycleCleanup in interface ExecutionLifecycleCleanable

Parameters:

executionContext - The ExecutionContext.