org.jboss.soa.esb.actions.routing
Class JMSRouter
java.lang.Object
org.jboss.soa.esb.actions.AbstractActionLifecycle
org.jboss.soa.esb.actions.AbstractActionPipelineProcessor
org.jboss.soa.esb.actions.routing.AbstractRouter
org.jboss.soa.esb.actions.routing.JMSRouter
- All Implemented Interfaces:
- ActionLifecycle, ActionPipelineProcessor
public class JMSRouter
- extends AbstractRouter
JSM Routing Action Processor.
Sample Action Configuration:
<action class="org.jboss.soa.esb.actions.routing.JMSRouter">
jndiName="queue/A"
message-prop->prop-name<=">prop-value<" >!-- (Optional)--<
unwrap="true/false" >!-- (Optional - default false)--<
/>
Note how properties to be set on the message are prefixed with "message-prop-".
To unwrap the message payload from the message before routing, set the "unwrap" property to "true".
TODO: Add support for JMS Topic destinations.
- Since:
- Version 4.0
- Author:
- tom.fennelly@jboss.com
Methods inherited from class java.lang.Object |
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JMSRouter
public JMSRouter(ConfigTree propertiesTree)
throws ConfigurationException,
javax.naming.NamingException,
javax.jms.JMSException
- Public constructor.
- Parameters:
propertiesTree
- Action properties.
- Throws:
ConfigurationException
- Queue name not configured.
javax.jms.JMSException
- Unable to configure JMS destination.
javax.naming.NamingException
- Unable to configure JMS destination.
JMSRouter
public JMSRouter(java.lang.String actionName,
java.util.List<KeyValuePair> properties)
throws ConfigurationException
- Public constructor.
- Parameters:
actionName
- Action name.properties
- Action properties.
- Throws:
ConfigurationException
- Queue name not configured.
javax.jms.JMSException
- Unable to configure JMS destination.
javax.naming.NamingException
- Unable to configure JMS destination.
route
public void route(java.lang.Object message)
throws ActionProcessingException
- Description copied from class:
AbstractRouter
- Route the message or message payload.
If the message is to be unwrapped, it will have been unwrapped at this stage.
- Specified by:
route
in class AbstractRouter
- Parameters:
message
- The object to route.
- Throws:
ActionProcessingException
- Exception during routing operation.
getOkNotification
public java.io.Serializable getOkNotification(Message message)
getErrorNotification
public java.io.Serializable getErrorNotification(Message message)
finalize
protected void finalize()
throws java.lang.Throwable
- Overrides:
finalize
in class java.lang.Object
- Throws:
java.lang.Throwable