ActiveMQ - JMS to JMS Bridge

Introduction

ActiveMQ provides bridging functionality to other JMS providers that implement the JMS 1.0.2 and above specification.
A JMS bridge can be co-located with an ActiveMQ broker or run remotely.
In order to support JMS 1.0.2 there is seperation between Queues and Topics.

temporary destinations and replyTo destinations in the inbound message exchanges are automatically handled, enabling an ActiveMQ service to handle a foreign JMS TopicRequestor or QueueResquestor exchanges.

properties

JMS Bridge Topic Connector

+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
property name default value description
localTopicConnection null if set will be used to connect to ActiveMQ
localTopicConnectionFactory null used to initialize the ActiveMQ JMS Connection if localTopicConnection is not set
jndiLocalTemplate Spring default template used for locating the Connection Factory for the ActiveMQ Connection if the localTopicConnection or localTopicConnectionFactory is not set
outboundTopicConnection null if set will be used to connect to the foreign JMS provider
outboundTopicConnectionFactory null used to initialize the foreign JMS Connection if localTopicConnection is not set
jndiOutboundTemplate Spring default template used for locating the Connection Factory for the ActiveMQ Connection if the localTopicConnection or localTopicConnectionFactory is not set
localUsername null if set will be used for authentication to the ActiveMQ JMS provider
localPassword null if set will be used for authentication to the ActiveMQ JMS provider
outboundUsername null if set will be used for authentication to the foreign JMS provider
outboundPassword null if set will be used for authentication to the foreign JMS provider
inboundMessageConvertor null if set will be used for converting foreign JMS Messages to a format for ActiveMQ
outboundMessageConvertor null if set will be used for converting ActiveMQ messages to a format for the foriegn JMS provider
inboundTopicBridges null an array of InboundTopicBridge instances - used for defining inbound (subscribe to) traffic from the foreign JMS provider
outboundTopicBridges null an array of OutboundTopicBridge instances - used for defining destinations that will be published to the foreign JMS provider
+

JMS Bridge Queue Connector

+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
property name default value description
localQueueConnection null if set will be used to connect to ActiveMQ
localQueueConnectionFactory null used to initialize the ActiveMQ JMS Connection if localQueueConnection is not set
jndiLocalTemplate Spring default template used for locating the Connection Factory for the ActiveMQ Connection if the localQueueConnection or localQueueConnectionFactory is not set
outboundQueueConnection null if set will be used to connect to the foreign JMS provider
outboundQueueConnectionFactory null used to initialize the foreign JMS Connection if localQueueConnection is not set
jndiOutboundTemplate Spring default template used for locating the Connection Factory for the ActiveMQ Connection if the localQueueConnection or localQueueConnectionFactory is not set
localUsername null if set will be used for authentication to the ActiveMQ JMS provider
localPassword null if set will be used for authentication to the ActiveMQ JMS provider
outboundUsername null if set will be used for authentication to the foreign JMS provider
outboundPassword null if set will be used for authentication to the foreign JMS provider
inboundMessageConvertor null if set will be used for converting foreign JMS Messages to a format for ActiveMQ
outboundMessageConvertor null if set will be used for converting ActiveMQ messages to a format for the foriegn JMS provider
inboundQueueBridges null an array of InboundTopicBridge instances - used for defining inbound (subscribe to) traffic from the foreign JMS provider
outboundTopicBridges null an array of OutboundTopicBridge instances - used for defining destinations that will be published to the foreign JMS provider
+

InboundTopicBridge

+ + + + + + + + + + + + + + + + + + + + + + + +
property name default value description
consumerTopic null the topic to subscribe to
selector null selector to use - if any
consumerName null if set will create a durable consumer
+

OutboundTopicBridge

+ + + + + + + + + + + + + +
property name default value description
producerTopic null the topic to publish to
+

InboundQueueBridge

+ + + + + + + + + + + + + + + + + + +
property name default value description
consumerQueue null the queue to receive from
selector null selector to use - if any
+

OutboundQueueBridge

+ + + + + + + + + + + + + +
property name default value description
producerQueue null the queue to send to
+

Example Configuration

This is part of an example configuration of a Broker - bridging to a Foreign JMS provider

<!-- local broker with embedded Jms to Jms bridge (ok - it's contrived) -->
+  <bean id="localbroker" class="org.apache.activemq.broker.BrokerService" 
+    init-method="start">
+    <property name="brokerName" value = "localBroker"/>
+      <property name="persistent" value = "false"/>
+    <property name="transportConnectorURIs">
+      <list>
+        <value>tcp://localhost:61234</value>
+      </list>
+    </property>
+    <property name="jmsBridgeConnectors">
+      <list>
+      	<ref bean="jmsConnector"/>
+      </list>
+    </property>
+  </bean>
+  
+  <!-- JMS ConnectionFactory to use local broker (the one with the bridge) -->
+  <bean id="localFactory"
+    class="org.apache.activemq.ActiveMQConnectionFactory">
+    <property name="brokerURL" value="tcp://localhost:61234" />
+  </bean>
+  
+  <!--JmsTopicConnector - the Jms bridge -->
+  <bean id="jmsConnector"
+  	class="org.apache.activemq.network.jms.JmsTopicConnector">
+  	<property name = "outboundTopicConnectionFactory" ref = "remoteFactory"/>
+  	
+  	<property name = "inboundTopicBridges">
+  	 <list>
+  	  <ref bean="InboundTopicBridge" />
+  	 </list>
+  	 </property>
+
+  </bean>
+
+  <bean id ="InboundTopicBridge" class="org.apache.activemq.network.jms.InboundTopicBridge">
+  	<property name = "inboundTopicName" value = "org.apache.activemq.network.jms.TopicBridgeSpringTest"/>
+  </bean>
+</beans>

java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory + +# use the following property to configure the default connector +java.naming.provider.url = vm://localhost + +# use the following property to specify a class path resource or URL +# used to configure an embedded broker using the XML configuration file +#brokerXmlConfig = file:src/conf/sample-conf/default.xml + +# use the following property to specify the JNDI name the connection factory +# should appear as. +#connectionFactoryNames = connectionFactory, queueConnectionFactory, topicConnectionFactry + +# register some queues in JNDI using the form +# queue.[jndiName] = [physicalName] +queue.MyQueue = example.MyQueue + + +# register some topics in JNDI using the form +# topic.[jndiName] = [physicalName] +topic.MyTopic = example.MyTopic

Name

Value

Name

Value

java.naming.factory.initial

org.activemq.jndi.ActiveMQInitialContextFactory

java.naming.factory.initial

org.apache.activemq.jndi.ActiveMQInitialContextFactory

java.naming.provider.url

Tcp://hostname:61616

java.naming.provider.url

Tcp://hostname:61616

topic.MyTopic

example.MyTopic

topic.MyTopic

example.MyTopic

Sample code

// create a new intial context, which loads from jndi.properties file javax.naming.Context ctx = new javax.naming.InitialContext(); @@ -253,23 +272,18 @@ // create a new subscriber to receive messages javax.jms.TopicSubscriber subscriber = session.createSubscriber(mytopic);

Example recommended by specification

import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.Destination; +import javax.jms.JMSException; +import javax.jms.MessageProducer; +import javax.jms.Session; +import javax.jms.TextMessage; +import javax.naming.Context; +import javax.naming.InitialContext; +import javax.naming.NamingException; + +/** + * A simple polymorphic JMS producer which can work with Queues or Topics + * which uses JNDI to lookup the JMS connection factory and destination + * + * @version $Revision: 1.2 $ + */ +public class SimpleProducer { + + private static final org.apache.commons.logging.Log log = org.apache.commons.logging.LogFactory + .getLog(SimpleProducer.class); + + /** + * @param args the destination name to send to and optionally, the number of messages to send + */ + public static void main(String[] args) { + Context jndiContext = null; + ConnectionFactory connectionFactory = null; + Connection connection = null; + Session session = null; + Destination destination = null; + MessageProducer producer = null; + String destinationName = null; + final int NUM_MSGS; + + if ((args.length < 1) || (args.length > 2)) { + log.info("Usage: java SimpleProducer <destination-name> [<number-of-messages>]"); + System.exit(1); + } + destinationName = args[0]; + log.info("Destination name is " + destinationName); + if (args.length == 2) { + NUM_MSGS = (new Integer(args[1])).intValue(); + } + else { + NUM_MSGS = 1; + } + + /* + * Create a JNDI API InitialContext object + */ + try { + jndiContext = new InitialContext(); + } + catch (NamingException e) { + log.info("Could not create JNDI API context: " + e.toString()); + System.exit(1); + } + + /* + * Look up connection factory and destination. + */ + try { + connectionFactory = (ConnectionFactory) jndiContext.lookup("ConnectionFactory"); + destination = (Destination) jndiContext.lookup(destinationName); + } + catch (NamingException e) { + log.info("JNDI API lookup failed: " + e); + System.exit(1); + } + + /* + * Create connection. + * Create session from connection; false means session is not transacted. + * Create sender and text message. + * Send messages, varying text slightly. + * Send end-of-messages message. + * Finally, close connection. + */ + try { + connection = connectionFactory.createConnection(); + session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + producer = session.createProducer(destination); + TextMessage message = session.createTextMessage(); + for (int i = 0; i < NUM_MSGS; i++) { + message.setText("This is message " + (i + 1)); + log.info("Sending message: " + message.getText()); + producer.send(message); + } + + /* + * Send a non-text control message indicating end of messages. + */ + producer.send(session.createMessage()); + } + catch (JMSException e) { + log.info("Exception occurred: " + e); + } + finally { + if (connection != null) { + try { + connection.close(); + } + catch (JMSException e) { + } + } + } + } +}

Overview

Community

Using ActiveMQ

Features

Connectivitiy

Utilities

External Tools

Related Projects

Support

Developers

Tools we use

Feeds

Introduction

properties

Example Configuration

Features

Connectivitiy

Features

Connectivitiy

Features

Connectivitiy

ActiveMQ JNDI Tutorial

Example Java code

Features

Connectivitiy

Features

Connectivitiy

Features

Connectivitiy

Features

Connectivitiy

Features

Connectivitiy

Features

Connectivitiy