org.jboss.soa.esb.actions
Class CbrProxyAction

java.lang.Object
  org.jboss.soa.esb.actions.CbrProxyAction

All Implemented Interfaces:

ActionProcessor

public class CbrProxyAction
extends java.lang.Object
implements ActionProcessor

Action proxy to call the Content Based Router.

Author:

kstam@redhat.com

Field Summary

protected ConfigTree	_config Configuration Tree
protected java.util.Collection<EPR>	_eprs Collection of EPRS for the Content Based Router

Constructor Summary

CbrProxyAction(ConfigTree config)
Constructor of the Content Based Router Proxy.

Method Summary

Message	deliver(Message message) Do *not* route, just deliver.
void	exceptionCallback(Message message, java.lang.Throwable t)
java.io.Serializable	getErrorNotification(Message message) Get the "Error" notification message for this processor.
java.io.Serializable	getOkNotification(Message message) Get the "OK" notification message for this processor.
Message	noOperation(Message message) No-Op method.
void	okMethod(Message message)
Message	process(Message message) By default this process method forwards this request to routeAndDeliver.
Message	route(Message message) Just route.
Message	routeAndDeliver(Message message) Route and Deliver to the destination Services.

Methods inherited from class java.lang.Object

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

Field Detail

_eprs

protected java.util.Collection<EPR> _eprs

Collection of EPRS for the Content Based Router

_config

protected ConfigTree _config

Configuration Tree

Constructor Detail

CbrProxyAction

public CbrProxyAction(ConfigTree config)
               throws RegistryException

Constructor of the Content Based Router Proxy. This constructor obtains the EPRs of the Content Based Router.

Parameters:

config -

Throws:

java.lang.Exception

RegistryException

Method Detail

noOperation

public Message noOperation(Message message)

No-Op method. This is here for notification purposes.

Parameters:

message -

Returns:

the same message as passed in.

process

public Message process(Message message)

By default this process method forwards this request to routeAndDeliver.

Specified by:

process in interface ActionProcessor

Parameters:

message - - the message to be routed.

Returns:

- the same message as was passed in.

See Also:

routeAndDeliver(Message message).

route

public Message route(Message message)
              throws MessageRouterException

Just route. The routing returns the message with a Collection of destinationService names.

Parameters:

message -

Returns:

message, a collection of service destinations is added to the message.

Throws:

MessageRouterException

deliver

public Message deliver(Message message)

Do *not* route, just deliver. Pulls the destinationServices from the message and deliver the message to the destination(s).

Parameters:

message -

Returns:

routeAndDeliver

public Message routeAndDeliver(Message message)

Route and Deliver to the destination Services.

Parameters:

message - - to be routed and delivered

Returns:

message - same message is returned

exceptionCallback

public void exceptionCallback(Message message,
                              java.lang.Throwable t)

okMethod

public void okMethod(Message message)

getErrorNotification

public java.io.Serializable getErrorNotification(Message message)

Description copied from interface: ActionProcessor

Get the "Error" notification message for this processor.

Specified by:

getErrorNotification in interface ActionProcessor

Parameters:

message - The message Object.

Returns:

The Error message.

getOkNotification

public java.io.Serializable getOkNotification(Message message)

Description copied from interface: ActionProcessor

Get the "OK" notification message for this processor.

Specified by:

getOkNotification in interface ActionProcessor

Parameters:

message - The message Object.

Returns:

The OK message.