org.milyn.routing.jms

Class JMSRouter

java.lang.Object

org.milyn.routing.jms.JMSRouter

All Implemented Interfaces:

org.milyn.delivery.ContentHandler, org.milyn.delivery.dom.DOMElementVisitor, org.milyn.delivery.dom.DOMVisitAfter, org.milyn.delivery.dom.DOMVisitBefore, org.milyn.delivery.dom.DOMVisitor, org.milyn.delivery.ordering.Consumer, org.milyn.delivery.sax.SAXVisitAfter, org.milyn.delivery.sax.SAXVisitBefore, org.milyn.delivery.sax.SAXVisitor, org.milyn.delivery.Visitor

@VisitBeforeIf(condition="parameters.containsKey(\'executeBefore\') && parameters.executeBefore.value == \'true\'")
 @VisitAfterIf(condition="!parameters.containsKey(\'executeBefore\') || parameters.executeBefore.value != \'true\'")
public class JMSRouter
extends Object
implements org.milyn.delivery.dom.DOMElementVisitor, org.milyn.delivery.sax.SAXVisitBefore, org.milyn.delivery.sax.SAXVisitAfter, org.milyn.delivery.ordering.Consumer

Router is a Visitor for DOM or SAX elements. It sends the content as a JMS Message object to the configured destination.

The type of the JMS Message is determined by the "messageType" config param.

Example configuration:

 <resource-config selector="orderItems">
    <resource>org.milyn.routing.jms.JMSRouter</resource>
    <param name="beanId">beanId</param>
    <param name="destinationName">/queue/smooksRouterQueue</param>
 </resource-config>
        ....
 Optional parameters:
    <param name="executeBefore">true</param>
    <param name="jndiContextFactory">ConnectionFactory</param>
    <param name="jndiProviderUrl">jnp://localhost:1099</param>
    <param name="jndiNamingFactory">org.jboss.naming:java.naming.factory.url.pkgs=org.jnp.interfaces</param>
    <param name="connectionFactory">ConnectionFactory</param>
    <param name="deliveryMode">persistent</param>
    <param name="priority">10</param>
    <param name="timeToLive">100000</param>
    <param name="securityPrincipal">username</param>
    <param name="securityCredential">password</param>
    <param name="acknowledgeMode">AUTO_ACKNOWLEDGE</param>
    <param name="transacted">false</param>
    <param name="correlationIdPattern">orderitem-${order.orderId}-${order.orderItem.itemId}</param>
    <param name="messageType">ObjectMessage</param>
    <param name="highWaterMark">50</param>
    <param name="highWaterMarkTimeout">5000</param>
    <param name="highWaterMarkPollFrequency">500</param>
 

Description of configuration properties:

• jndiContextFactory: the JNDI ContextFactory to use.
• jndiProviderUrl: the JNDI Provider URL to use.
• jndiNamingFactory: the JNDI NamingFactory to use.
• connectionFactory: the ConnectionFactory to look up.
• deliveryMode: the JMS DeliveryMode. 'persistent'(default) or 'non-persistent'.
• priority: the JMS Priority to be used.
• timeToLive: the JMS Time-To-Live to be used.
• securityPrincipal: security principal use when creating the JMS connection.
• securityCredential: the security credentials to use when creating the JMS connection.
• acknowledgeMode: the acknowledge mode to use. One of 'AUTO_ACKNOWLEDGE'(default), 'CLIENT_ACKNOWLEDGE', 'DUPS_OK_ACKNOWLEDGE'.
• transacted: determines if the session should be transacted. Defaults to 'false'.
• correlationIdPattern: JMS Correlation pattern that will be used for the outgoing message. Supports templating.
• messageType: type of JMS Message that should be sent. 'TextMessage'(default), 'ObjectMessage' or 'MapMessage'.
• highWaterMark: max number of messages that can be sitting in the JMS Destination at any any time. Default is 200.
• highWaterMarkTimeout: number of ms to wait for the system to process JMS Messages from the JMS destination so that the number of JMS Messages drops below the highWaterMark. Default is 60000 ms.
• highWaterMarkPollFrequency: number of ms to wait between checks on the High Water Mark, while waiting for it to drop. Default is 1000 ms.

Since:

1.0

Author:

Daniel Bevenius

Constructor Summary

Constructors

Constructor and Description
JMSRouter()

Method Summary

Modifier and Type	Method and Description
protected void	close(javax.jms.Connection connection)
protected void	close(javax.jms.Session session)
boolean	consumes(Object object)
protected javax.jms.MessageProducer	createMessageProducer(javax.jms.Destination destination, Context context)
String	getAcknowledgeMode()
String	getConnectionFactoryName()
String	getDeliveryMode()
javax.jms.Destination	getDestination()
String	getDestinationName()
String	getJndiContextFactory()
String	getJndiNamingFactoryUrl()
String	getJndiProviderUrl()
int	getPriority()
String	getSecurityCredential()
String	getSecurityPrincipal()
long	getTimeToLive()
void	initialize()
boolean	isTransacted()
protected void	sendMessage(javax.jms.Message message)
void	setAcknowledgeMode(String jmsAcknowledgeMode)
void	setBeanId(String beanId)
void	setConnectionFactoryName(String connectionFactoryName)
void	setCorrelationIdPattern(String correlationIdPattern)
void	setDeliveryMode(String deliveryMode)
void	setDestinationName(String destinationName)
void	setHighWaterMark(int highWaterMark)
void	setHighWaterMarkPollFrequency(long highWaterMarkPollFrequency)
void	setHighWaterMarkTimeout(long highWaterMarkTimeout)
void	setJndiContextFactory(String contextFactory)
void	setJndiNamingFactoryUrl(String pkgUrl)
void	setJndiProperties(Properties properties)
void	setJndiProperties(String propertiesFile)
void	setJndiProviderUrl(String providerUrl)
protected void	setMessageProducerProperties() Sets the following MessageProducer properties: TimeToLive Priority DeliveryMode
void	setMessageType(String messageType)
void	setMsgCreationStrategy(MessageCreationStrategy msgCreationStrategy)
void	setPriority(int priority)
void	setSecurityCredential(String securityCredential)
void	setSecurityPrincipal(String securityPrincipal)
void	setTimeToLive(long timeToLive)
void	setTransacted(boolean transacted)
void	uninitialize()
void	visitAfter(Element element, org.milyn.container.ExecutionContext execContext)
void	visitAfter(org.milyn.delivery.sax.SAXElement element, org.milyn.container.ExecutionContext execContext)
void	visitBefore(Element element, org.milyn.container.ExecutionContext execContext)
void	visitBefore(org.milyn.delivery.sax.SAXElement element, org.milyn.container.ExecutionContext execContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSRouter

public JMSRouter()

Method Detail

initialize

@Initialize
public void initialize()
                            throws org.milyn.cdr.SmooksConfigurationException,
                                   javax.jms.JMSException

Throws:

org.milyn.cdr.SmooksConfigurationException

javax.jms.JMSException

uninitialize

@Uninitialize
public void uninitialize()
                                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

consumes

public boolean consumes(Object object)

Specified by:

consumes in interface org.milyn.delivery.ordering.Consumer

setBeanId

public void setBeanId(String beanId)

setCorrelationIdPattern

public void setCorrelationIdPattern(String correlationIdPattern)

setHighWaterMark

public void setHighWaterMark(int highWaterMark)

setHighWaterMarkTimeout

public void setHighWaterMarkTimeout(long highWaterMarkTimeout)

setHighWaterMarkPollFrequency

public void setHighWaterMarkPollFrequency(long highWaterMarkPollFrequency)

setJndiContextFactory

@ConfigParam(use=OPTIONAL)
public void setJndiContextFactory(String contextFactory)

setJndiProperties

@ConfigParam(use=OPTIONAL)
public void setJndiProperties(String propertiesFile)

setJndiProperties

public void setJndiProperties(Properties properties)

setJndiProviderUrl

@ConfigParam(use=OPTIONAL)
public void setJndiProviderUrl(String providerUrl)

setJndiNamingFactoryUrl

@ConfigParam(use=OPTIONAL)
public void setJndiNamingFactoryUrl(String pkgUrl)

setDestinationName

@ConfigParam(use=REQUIRED)
public void setDestinationName(String destinationName)

setDeliveryMode

@ConfigParam(choice={"persistent","non-persistent"},
             defaultVal="persistent",
             use=OPTIONAL)
public void setDeliveryMode(String deliveryMode)

setTimeToLive

@ConfigParam(use=OPTIONAL)
public void setTimeToLive(long timeToLive)

setSecurityPrincipal

@ConfigParam(use=OPTIONAL)
public void setSecurityPrincipal(String securityPrincipal)

setSecurityCredential

@ConfigParam(use=OPTIONAL)
public void setSecurityCredential(String securityCredential)

setTransacted

@ConfigParam(use=OPTIONAL,
             defaultVal="false")
public void setTransacted(boolean transacted)

setConnectionFactoryName

@ConfigParam(defaultVal="ConnectionFactory",
             use=OPTIONAL)
public void setConnectionFactoryName(String connectionFactoryName)

setPriority

@ConfigParam(use=OPTIONAL)
public void setPriority(int priority)

setAcknowledgeMode

@ConfigParam(defaultVal="AUTO_ACKNOWLEDGE",
             choice={"AUTO_ACKNOWLEDGE","CLIENT_ACKNOWLEDGE","DUPS_OK_ACKNOWLEDGE"})
public void setAcknowledgeMode(String jmsAcknowledgeMode)

setMessageType

@ConfigParam(defaultVal="TextMessage",
             choice={"TextMessage","ObjectMessage"})
public void setMessageType(String messageType)

visitAfter

public void visitAfter(Element element,
                       org.milyn.container.ExecutionContext execContext)
                throws org.milyn.SmooksException

Specified by:

visitAfter in interface org.milyn.delivery.dom.DOMVisitAfter

Throws:

org.milyn.SmooksException

visitBefore

public void visitBefore(Element element,
                        org.milyn.container.ExecutionContext execContext)
                 throws org.milyn.SmooksException

Specified by:

visitBefore in interface org.milyn.delivery.dom.DOMVisitBefore

Throws:

org.milyn.SmooksException

visitAfter

public void visitAfter(org.milyn.delivery.sax.SAXElement element,
                       org.milyn.container.ExecutionContext execContext)
                throws org.milyn.SmooksException,
                       IOException

Specified by:

visitAfter in interface org.milyn.delivery.sax.SAXVisitAfter

Throws:

org.milyn.SmooksException

IOException

visitBefore

public void visitBefore(org.milyn.delivery.sax.SAXElement element,
                        org.milyn.container.ExecutionContext execContext)
                 throws org.milyn.SmooksException,
                        IOException

Specified by:

visitBefore in interface org.milyn.delivery.sax.SAXVisitBefore

Throws:

org.milyn.SmooksException

IOException

createMessageProducer

protected javax.jms.MessageProducer createMessageProducer(javax.jms.Destination destination,
                                                          Context context)
                                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

setMessageProducerProperties

protected void setMessageProducerProperties()
                                     throws org.milyn.cdr.SmooksConfigurationException

Sets the following MessageProducer properties:

TimeToLive Priority DeliveryMode

Subclasses may override this behaviour.

Throws:

org.milyn.cdr.SmooksConfigurationException

sendMessage

protected void sendMessage(javax.jms.Message message)
                    throws SmooksRoutingException

Throws:

SmooksRoutingException

close

protected void close(javax.jms.Connection connection)

close

protected void close(javax.jms.Session session)

getDestination

public javax.jms.Destination getDestination()

getJndiContextFactory

public String getJndiContextFactory()

getJndiProviderUrl

public String getJndiProviderUrl()

getJndiNamingFactoryUrl

public String getJndiNamingFactoryUrl()

getDestinationName

public String getDestinationName()

getDeliveryMode

public String getDeliveryMode()

getTimeToLive

public long getTimeToLive()

getSecurityPrincipal

public String getSecurityPrincipal()

getSecurityCredential

public String getSecurityCredential()

isTransacted

public boolean isTransacted()

getConnectionFactoryName

public String getConnectionFactoryName()

getPriority

public int getPriority()

getAcknowledgeMode

public String getAcknowledgeMode()

setMsgCreationStrategy

public void setMsgCreationStrategy(MessageCreationStrategy msgCreationStrategy)