ActiveMQ - How do I create new destinations

In many messaging topologies there are JMS Brokers (server side) and a JMS client side. Often it makes sense to deploy a broker within your JVM. This allows you to optimise away a network hop; making the networking of JMS as efficient as pure RMI, but with all the usual JMS features of location independence, reliability, load balancing etc.

In ActiveMQ 4.x

There are various ways to embed a broker in ActiveMQ 4.x depending on if you are using Java, Spring or XBean.

Using Java code

The following Java code will create an embedded broker

BrokerService broker = new BrokerService();
+
+// configure the broker
+broker.addConnector("tcp://localhost:61616");
+
+broker.start();

Using Spring

There is a factory bean that can refer to an external ActiveMQ XML configuration file

<bean id="broker" class="org.activemq.xbean.BrokerFactoryBean">
+    <property name="config" value="classpath:org/activemq/xbean/activemq.xml" />
+    <property name="start" value="true" />
+  </bean>

Using XBean

If you are already using XBean then you can just mix and match your Spring/XBean XML configuration with ActiveMQ's configuration.

<beans xmlns="http://activemq.org/config/1.0">
+
+  <broker useJmx="true">
+
+    <persistenceAdapter>
+      <journaledJDBC journalLogFiles="5" dataDirectory="foo" />
+    </persistenceAdapter>
+
+    <transportConnectors>
+      <transportConnector uri="tcp://localhost:61636" />
+    </transportConnectors>
+
+    <networkConnectors>
+      <networkConnector uri="static://(tcp://localhost:61616)" />
+    </networkConnectors>
+  </broker>
+
+</beans>

In ActiveMQ 3.x

You can embed a JMS Broker inside your JMS client via a simple property on the ActiveMQConnectionFactory class. Just set the useEmbeddedBroker property.

ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory();
+factory.setUseEmbeddedBroker(true);
+Connection connection = factory.createConnection();

If you wish to customize the broker using the Xml Configuration and normal Java properties then you can do the following

[Unable to download http://activemq.codehaus.org/checkout/activemq/modules/assembly/src/test/org/activemq/config/BrokerXmlConfigTest.java : http://activemq.codehaus.org/checkout/activemq/modules/assembly/src/test/org/activemq/config/BrokerXmlConfigTest.java]

Or you could configure the factory above using JNDI.

Using Spring

If you are using Spring then you can deploy an ActiveMQ broker directly into Spring as follows...

<!-- lets deploy an embedded broker in this spring.xml -->
+  <bean id="broker" class="org.activemq.spring.BrokerFactoryBean">
+    <property name="config" value="classpath:foo/bar/broker.xml"/>
+  </bean>

or if you prefer you can configure the connection factory in Spring directly.

<bean id="jmsFactory" class="org.activemq.ActiveMQConnectionFactory">
+    <property name="brokerURL">
+      <value>vm://localhost</value>
+    </property>
+    <property name="useEmbeddedBroker">
+      <value>true</value>
+    </property>
+    <!-- specify that the ActiveMQ XML config file should be used to configure the Broker -->
+    <property name="brokerXmlConfig">
+      <value>org/activemq/spring/example.xml</value>
+    </property>
+  </bean>

Using Java code

If you want to you could just configure the broker directly in Java code.

BrokerContainer roker = new BrokerContainerImpl("TestLargeMessages");
+broker.addConnector("tcp://localhost:61616");
+broker.start();

Overview

Community

Using ActiveMQ

Features

Connectivitiy

Utilities

External Tools

Related Projects

Support

Developers

Tools we use

Feeds

Overview

Community

Using ActiveMQ

Features

Connectivitiy

Utilities

External Tools

Related Projects

Support

Developers

Tools we use

Feeds

Overview

Community

Using ActiveMQ

Features

Connectivitiy

Utilities

External Tools

Related Projects

Support

Developers

Tools we use

Feeds

Overview

Community

Using ActiveMQ

Features

Connectivitiy

Utilities

External Tools

Related Projects

Support

Developers

Tools we use

Feeds

In ActiveMQ 4.x

Using Java code

Using Spring

Using XBean

In ActiveMQ 3.x

Using Spring

Using Java code

Overview

Community

Using ActiveMQ

Features

Connectivitiy

Utilities

External Tools

Related Projects

Support

Developers

Tools we use

Feeds