Easy Messaging with STOMP over WebSockets using ActiveMQ and HornetQ

喜欢ヅ旅行 2022-08-06 11:09 71阅读 0赞

[Andriy Redko \{devmind\}][Andriy Redko _devmind]

## Saturday, June 29, 2013 ##

Messaging is an extremely powerful tool for building distributed software systems of different levels. Typically, at least in Java ecosystem, the client (front-end) never interacts with message broker (or exchange) directly but does it by invoking server-side (back-end) services. Or client may not even be aware that there's messaging solution in place.

With [Websockets][] gaining more and more adoption, and wide support of the text-oriented protocols like[STOMP][] (used to communicate with message broker or exchange) are going to make a difference. Today's post will try to explain how simple it is to expose two very popular[JMS][] implementations, Apache[ActiveMQ][] and JBoss[HornetQ][], to be available to web front-end (JavaScript) using[STOMP][] over[Websockets][].

Before digging into the code, one might argue that it's not a good idea to do that. So what's the purpose? The answer really depends:

*  you are developing prototype / proof of concept and need easy way to integrate publish/subscribe or peer-to-peer messaging
 *  you don't want / need to build sophisticated architecture and the simplest solution which works is just enough

The scalability, fail-over and a lot of other very important decisions are not taken into consideration here but definitely should be if you are developing robust and resilient architecture.

So let's get started. As always, it's better to start with problem we're trying to solve: we would like to develop simple publish/subscribe solution where web client written in JavaScript will be able to send messages and listen for a specific topic. Whenever any message has been received, client just shows simple alert window. Please note that we need to use modern browser which supports[Websockets][], such as[Google Chrome][] or[Mozilla Firefox][].

For both our examples client's code remains the same and so let's start with that. The great starting point is[STOMP Over WebSocket][] article which introduces the[stomp.js][] module and here is our**index.html**:

[view source][] [print][] [?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>&lt;script src=</code><code>"stomp.js"</code><code>&gt;&lt;/script&gt;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>03</code></td> 
   <td><code>&lt;script type=</code><code>"text/javascript"</code><code>&gt;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>04</code></td> 
   <td><code>&nbsp;</code><code>var</code><code>client = Stomp.client(</code><code>"<a rel="nofollow"><span style="color:#448888">ws://localhost:61614/stomp</span></a>"</code><code>,</code><code>"v11.stomp"</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>06</code></td> 
   <td><code>&nbsp;</code><code>client.connect(</code><code>""</code><code>,</code><code>""</code><code>,</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>07</code></td> 
   <td><code>&nbsp;&nbsp;</code><code>function</code><code>() { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>08</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>client.subscribe(</code><code>"jms.topic.test"</code><code>,</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>09</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>function</code><code>( message ) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>10</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>alert( message );</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>12</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ priority: 9 }</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>15</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;</code><code>client.send(</code><code>"jms.topic.test"</code><code>, { priority: 9 },</code><code>"Pub/Sub over STOMP!"</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>19</code></td> 
   <td><code>&lt;/script&gt;</code></td> 
  </tr> 
 </tbody> 
</table>

Extremely simple code but few details are worth to explain. First, we are looking for[Websockets][] endpoint at**ws://localhost:61614/stomp**. It's sufficient for local deployment but better to replace**localhost** with real IP address or host name. Secondly, once connected, client subscribes to the topic (only interested in messages with**priority: 9**) and publishes the message to this topic immediately after. From client prospective, we are done.

Let's move on to message broker and our first one in list is Apache [ ActiveMQ][ActiveMQ]. To make the example simple, we will embed Apache[ActiveMQ][] broker into simple[Spring][] application without using configuration XML files. As source code is available on[GitHub][], I will skip the POM file snippet and just show the code:

[view source][] [print][] [?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>package</code> <code> com.example.messaging;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>03</code></td> 
   <td><code>import</code> <code> java.util.Collections;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>05</code></td> 
   <td><code>import</code> <code> org.apache.activemq.broker.BrokerService;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>06</code></td> 
   <td><code>import</code> <code> org.apache.activemq.broker.jmx.ManagementContext;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>07</code></td> 
   <td><code>import</code> <code> org.apache.activemq.command.ActiveMQDestination;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>08</code></td> 
   <td><code>import</code> <code> org.apache.activemq.command.ActiveMQTopic;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>09</code></td> 
   <td><code>import</code> <code> org.apache.activemq.hooks.SpringContextHook;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>10</code></td> 
   <td><code>import</code> <code> org.springframework.context.annotation.Bean;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>11</code></td> 
   <td><code>import</code> <code> org.springframework.context.annotation.Configuration;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>13</code></td> 
   <td><code>@Configuration</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>14</code></td> 
   <td><code>public</code> <code> class</code> <code>AppConfig { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>15</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Bean</code><code>( initMethod =</code><code>"start"</code><code>, destroyMethod =</code><code>"stop"</code><code>)</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>16</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code><code>BrokerService broker()</code><code>throws</code><code>Exception { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>17</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code><code>BrokerService broker =</code><code>new</code><code>BrokerService();&nbsp;&nbsp;&nbsp;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>18</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>broker.addConnector(</code><code>"<a rel="nofollow"><span style="color:#448888">ws://localhost:61614</span></a>"</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>19</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>broker.setPersistent(</code><code>false</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>20</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>broker.setShutdownHooks( Collections.&lt; Runnable &gt;singletonList(</code><code>new</code><code>SpringContextHook() ) );</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>22</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code><code>ActiveMQTopic topic =</code><code>new</code><code>ActiveMQTopic(</code><code>"jms.topic.test"</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>23</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>broker.setDestinations(</code><code>new</code><code>ActiveMQDestination[] { topic }&nbsp; );</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>25</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code><code>ManagementContext managementContext =</code><code>new</code><code>ManagementContext();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>26</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>managementContext.setCreateConnector(</code><code>true</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>27</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>broker.setManagementContext( managementContext );</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>29</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code><code>broker;</code></td> 
  </tr> 
 </tbody> 
</table>

As we can see, the [ ActiveMQ][ActiveMQ] broker is configured with**ws://localhost:61614** connector which assumes using[STOMP][] protocol. Also, we are creating JMS topic with name**jms.topic.test** and enabling JMX management instrumentation. And to run it, simple**Starter** class:

[view source][] [print][] [?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>package</code> <code> com.example.messaging;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>03</code></td> 
   <td><code>import</code> <code> org.springframework.context.ApplicationContext;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>04</code></td> 
   <td><code>import</code> <code> org.springframework.context.annotation.AnnotationConfigApplicationContext;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>06</code></td> 
   <td><code>public</code> <code> class</code> <code>Starter&nbsp; { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>07</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code><code>static</code><code>void</code> <code>main( String[] args ) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>08</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ApplicationContext context =</code><code>new</code><code>AnnotationConfigApplicationContext( AppConfig.</code><code>class</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

Now, having it up and running, let's open **index.html** file in browser, we should see something like that:

[![Message.STOMP.1.PNG][]][Message.STOMP.1.PNG]

Simple! For curious readers, [ ActiveMQ][ActiveMQ] uses [ Jetty][Jetty] **7.6.7.v20120910** for[Websockets][] support and won't work with latest[Jetty][] distributions.

Moving on, with respect to [ HornetQ][HornetQ] the implementations looks a bit different though not very complicated as well. As**Starter** class remains the same, the only change is the configuration:

[view source][] [print][] [?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>package</code> <code> com.example.hornetq;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>03</code></td> 
   <td><code>import</code> <code> java.util.Collections;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>04</code></td> 
   <td><code>import</code> <code> java.util.HashMap;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>05</code></td> 
   <td><code>import</code> <code> java.util.Map;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>07</code></td> 
   <td><code>import</code> <code> org.hornetq.api.core.TransportConfiguration;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>08</code></td> 
   <td><code>import</code> <code> org.hornetq.core.config.impl.ConfigurationImpl;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>09</code></td> 
   <td><code>import</code> <code> org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>10</code></td> 
   <td><code>import</code> <code> org.hornetq.core.remoting.impl.netty.TransportConstants;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>11</code></td> 
   <td><code>import</code> <code> org.hornetq.core.server.JournalType;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>12</code></td> 
   <td><code>import</code> <code> org.hornetq.jms.server.config.ConnectionFactoryConfiguration;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>13</code></td> 
   <td><code>import</code> <code> org.hornetq.jms.server.config.JMSConfiguration;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>14</code></td> 
   <td><code>import</code> <code> org.hornetq.jms.server.config.TopicConfiguration;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>15</code></td> 
   <td><code>import</code> <code> org.hornetq.jms.server.config.impl.ConnectionFactoryConfigurationImpl;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>16</code></td> 
   <td><code>import</code> <code> org.hornetq.jms.server.config.impl.JMSConfigurationImpl;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>17</code></td> 
   <td><code>import</code> <code> org.hornetq.jms.server.config.impl.TopicConfigurationImpl;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>18</code></td> 
   <td><code>import</code> <code> org.hornetq.jms.server.embedded.EmbeddedJMS;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>19</code></td> 
   <td><code>import</code> <code> org.springframework.context.annotation.Bean;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>20</code></td> 
   <td><code>import</code> <code> org.springframework.context.annotation.Configuration;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>22</code></td> 
   <td><code>@Configuration</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>23</code></td> 
   <td><code>public</code> <code> class</code> <code>AppConfig { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>24</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Bean</code><code>( initMethod =</code><code>"start"</code><code>, destroyMethod =</code><code>"stop"</code><code>)</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>25</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code><code>EmbeddedJMS broker()</code><code>throws</code><code>Exception { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>26</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code><code>ConfigurationImpl configuration =</code><code>new</code><code>ConfigurationImpl();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>27</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>configuration.setPersistenceEnabled(</code><code>false</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>28</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>configuration.setJournalType( JournalType.NIO );</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>29</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>configuration.setJMXManagementEnabled(</code><code>true</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>30</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>configuration.setSecurityEnabled(</code><code>false</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>32</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code><code>Map&lt; String, Object &gt; params =</code><code>new</code><code>HashMap&lt;&gt;();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>33</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>params.put( TransportConstants.HOST_PROP_NAME,</code><code>"localhost"</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>34</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>params.put( TransportConstants.PROTOCOL_PROP_NAME,</code><code>"stomp_ws"</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>35</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>params.put( TransportConstants.PORT_PROP_NAME,</code><code>"61614"</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>37</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code><code>TransportConfiguration stomp =</code><code>new</code><code>TransportConfiguration( NettyAcceptorFactory.</code><code>class</code><code>.getName(), params );</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>38</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>configuration.getAcceptorConfigurations().add( stomp );</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>39</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>configuration.getConnectorConfigurations().put(</code><code>"stomp_ws"</code><code>, stomp );</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>41</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code><code>ConnectionFactoryConfiguration cfConfig =</code><code>new</code><code>ConnectionFactoryConfigurationImpl(</code><code>"cf"</code><code>,</code><code>true</code><code>,</code><code>"/cf"</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>42</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cfConfig.setConnectorNames( Collections.singletonList(</code><code>"stomp_ws"</code><code>) );</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>44</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code><code>JMSConfiguration jmsConfig =</code><code>new</code><code>JMSConfigurationImpl();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>45</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>jmsConfig.getConnectionFactoryConfigurations().add( cfConfig );</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>47</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code><code>TopicConfiguration topicConfig =</code><code>new</code><code>TopicConfigurationImpl(</code><code>"test"</code><code>,</code><code>"/topic/test"</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>48</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>jmsConfig.getTopicConfigurations().add( topicConfig );</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>50</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code><code>EmbeddedJMS jmsServer =</code><code>new</code><code>EmbeddedJMS();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>51</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>jmsServer.setConfiguration( configuration );</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>52</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>jmsServer.setJmsConfiguration( jmsConfig );</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>54</code></td> 
   <td><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code><code>jmsServer;</code></td> 
  </tr> 
 </tbody> 
</table>

The complete source code is on [ GitHub][GitHub 1]. After running **Starter** class and openning**index.html** in browser, we should see very similar results:

[![Message.STOMP.2.PNG][]][Message.STOMP.2.PNG]

[HornetQ][] configuration looks a bit more verbose, however there are no additional dependencies involved except brilliant[Netty][] framework.

For my own curiosity, I replaced the [ ActiveMQ][ActiveMQ] broker with [ Apollo][Apollo] implementation. Though I succeeded with making it works as expected, I found the API to be very cumbersome, at least in current version**1.6**, so I haven't covered it in this post.

All sources are available on GitHub: [ Apache ActiveMQ example][GitHub] and [ JBoss HornetQ example][GitHub 1]

Posted by[Andriy Redko][] at [ 12:27 PM][12_27 PM]    [![icon18_edit_allbkg.gif][]][icon18_edit_allbkg.gif 1]

Labels:[ActiveMQ][ActiveMQ 1],[hornetq. spring][], [ jms][jms], [ stomp][stomp], [ stomp.js][stomp.js 1], [ websockets][websockets]

#### 6 comments: ####

[![christian posta][]][christian posta 1]

[christian posta][christian posta 1] said...

Great write up.  
  
Can you tell a little more about your config with Apollo? Let me know what you found to be cumbersome and I can help you out. Or change it to be more friendly :)  
  
Cheers!

[July 29, 2013 at 5:44 AM][July 29_ 2013 at 5_44 AM][![icon_delete13.gif][]][icon_delete13.gif 1]

[![Andriy Redko][Andriy Redko 1]][Andriy Redko]<img src="http://1.bp.blogspot.com/\_WNHv4iYKMe0/S2RnlNBCAKI/AAAAAAAAAA0/liRhama55ss/S45/photo.jpg" width="35" height="35" class="photo" alt="">

[Andriy Redko][] said...

Hi Christian,  
  
Thank you very much for the feedback (as your blog follower, I really appreciate that). Yes, I found Apollo API to be cumbersome and verbose. I don't mean it's bad but I think it's not expressive and intuitive enough. The example I've taken as a foundation is this one: https://github.com/apache/activemq-apollo/blob/trunk/apollo-distro/src/main/release/examples/java-embedded-broker/src/main/java/example/EmbeddedBroker.java  
  
Though everything worked out fine, I think Apollo API could be better. I understand there are a reasons for that and I would love to make my contributions.  
  
Thank you very much.  
  
Best Regards,  
Andriy Redko

[July 29, 2013 at 4:16 PM][July 29_ 2013 at 4_16 PM][![icon_delete13.gif][]][icon_delete13.gif 2]

[![jmesnil][christian posta]][jmesnil_christian posta]

[jmesnil][jmesnil_christian posta] said...

Hi,  
  
Great introduction article.  
  
There is only a minor issue in it.  
  
When you call client.subscribe(destination, callback, \{ priority: 9\}); this does \*not\* mean that the callback will be called only for messages with priority = 9.  
The last argument is the headers sent by the SUBSCRIBE frame and will not have any effect.  
  
What you want is to pass a selector\[1\] header like this:  
  
client.subscribe(destination, callback, \{ selector: "priority=9" \});  
  
Please note that this is not specified in the STOMP protocol and may or may not be supported by the messaging brokers (both STOMP and ActiveMQ does support it).

[August 1, 2013 at 1:00 AM][August 1_ 2013 at 1_00 AM][![icon_delete13.gif][]][icon_delete13.gif 3]

[![Andriy Redko][Andriy Redko 1]][Andriy Redko]<img src="http://1.bp.blogspot.com/\_WNHv4iYKMe0/S2RnlNBCAKI/AAAAAAAAAA0/liRhama55ss/S45/photo.jpg" width="35" height="35" class="photo" alt="">

[Andriy Redko][] said...

Hi Jeff,  
  
Thank you very much for such a great clarification. That's definitely something I should have payed more attention to.  
  
Thank you!  
  
Best Regards,  
Andriy Redko

[August 1, 2013 at 2:24 PM][August 1_ 2013 at 2_24 PM][![icon_delete13.gif][]][icon_delete13.gif 4]

[![Zaw Min Tun][christian posta]][Zaw Min Tun_christian posta]

[Zaw Min Tun][Zaw Min Tun_christian posta] said...

Thanks for the great post.  
Is it possible to get the topic starting from the very beginning every time I connect to the topic?

[March 25, 2014 at 8:36 PM][March 25_ 2014 at 8_36 PM][![icon_delete13.gif][]][icon_delete13.gif 5]

[![Andriy Redko][Andriy Redko 1]][Andriy Redko]<img src="http://1.bp.blogspot.com/\_WNHv4iYKMe0/S2RnlNBCAKI/AAAAAAAAAA0/liRhama55ss/S45/photo.jpg" width="35" height="35" class="photo" alt="">

[Andriy Redko][] said...

Hi Zaw,  
  
Thanks a lot for the comments. As far as I know it is possible to do that in STOMP with durable subscriptions. I haven't done it personally but you may look at https://activemq.apache.org/how-do-durable-queues-and-topics-work.html and http://activemq.apache.org/apollo/documentation/stomp-manual.html\#Topic\_Durable\_Subscriptions for more details.  
  
Thanks.  
  
Best Regards,  
Andriy Redko

[March 26, 2014 at 10:00 AM][March 26_ 2014 at 10_00 AM][![icon_delete13.gif][]][icon_delete13.gif 6]

[Post a Comment][]

[Newer Post][] [Older Post][] [Home][Andriy Redko _devmind]

Subscribe to: [ Post Comments (Atom)][Post Comments _Atom]

[Andriy Redko _devmind]: http://aredko.blogspot.com/
[Websockets]: http://www.websocket.org/
[STOMP]: http://stomp.github.io/
[JMS]: https://java.net/projects/jms-spec/pages/Home
[ActiveMQ]: http://activemq.apache.org/
[HornetQ]: http://www.jboss.org/hornetq
[Google Chrome]: https://www.google.com/intl/en_ca/chrome/
[Mozilla Firefox]: http://www.mozilla.org/en-US/
[STOMP Over WebSocket]: http://jmesnil.net/stomp-websocket/doc/
[stomp.js]: https://raw.github.com/jmesnil/stomp-websocket/master/dist/stomp.js
[view source]: http://aredko.blogspot.com/2013/06/easy-messaging-with-stomp-over.html#viewSource
[print]: http://aredko.blogspot.com/2013/06/easy-messaging-with-stomp-over.html#printSource
[Link 1]: http://aredko.blogspot.com/2013/06/easy-messaging-with-stomp-over.html#about
[Spring]: http://www.springsource.org/spring-framework
[GitHub]: https://github.com/reta/spring-activemq-stomp-websockets
[Message.STOMP.1.PNG]: http://1.bp.blogspot.com/-hDwFkKoF2bI/Uc759ByLbRI/AAAAAAAAAGA/yG5lWgG67_0/s538/Message.STOMP.1.PNG
[Jetty]: http://www.eclipse.org/jetty/
[GitHub 1]: https://github.com/reta/spring-hornetq-stomp-websockets
[Message.STOMP.2.PNG]: http://4.bp.blogspot.com/-zYyXIuWKTEw/Uc790tNFcCI/AAAAAAAAAGQ/HSJSHyjMU_g/s439/Message.STOMP.2.PNG
[Netty]: http://netty.io/
[Apollo]: http://activemq.apache.org/apollo/
[Andriy Redko]: http://www.blogger.com/profile/16473725484333171169
[12_27 PM]: http://aredko.blogspot.com/2013/06/easy-messaging-with-stomp-over.html
[icon18_edit_allbkg.gif]: http://img2.blogblog.com/img/icon18_edit_allbkg.gif
[icon18_edit_allbkg.gif 1]: http://www.blogger.com/post-edit.g?blogID=8745745886722714957&postID=8175059268983332216&from=pencil
[ActiveMQ 1]: http://aredko.blogspot.com/search/label/ActiveMQ
[hornetq. spring]: http://aredko.blogspot.com/search/label/hornetq.%20spring
[jms]: http://aredko.blogspot.com/search/label/jms
[stomp]: http://aredko.blogspot.com/search/label/stomp
[stomp.js 1]: http://aredko.blogspot.com/search/label/stomp.js
[websockets]: http://aredko.blogspot.com/search/label/websockets
[christian posta]: http://img2.blogblog.com/img/b16-rounded.gif
[christian posta 1]: http://www.blogger.com/profile/10362980799120495299
[July 29_ 2013 at 5_44 AM]: http://aredko.blogspot.com/2013/06/easy-messaging-with-stomp-over.html?showComment=1375101899121#c7615619849865832629
[icon_delete13.gif]: http://www.blogger.com/img/icon_delete13.gif
[icon_delete13.gif 1]: http://www.blogger.com/delete-comment.g?blogID=8745745886722714957&postID=7615619849865832629
[Andriy Redko 1]: http://1.bp.blogspot.com/_WNHv4iYKMe0/S2RnlNBCAKI/AAAAAAAAAA0/liRhama55ss/S45/photo.jpg
[July 29_ 2013 at 4_16 PM]: http://aredko.blogspot.com/2013/06/easy-messaging-with-stomp-over.html?showComment=1375139764917#c7263466281519596684
[icon_delete13.gif 2]: http://www.blogger.com/delete-comment.g?blogID=8745745886722714957&postID=7263466281519596684
[jmesnil_christian posta]: http://www.blogger.com/profile/16529476669001423527
[August 1_ 2013 at 1_00 AM]: http://aredko.blogspot.com/2013/06/easy-messaging-with-stomp-over.html?showComment=1375344039005#c1407959530871257141
[icon_delete13.gif 3]: http://www.blogger.com/delete-comment.g?blogID=8745745886722714957&postID=1407959530871257141
[August 1_ 2013 at 2_24 PM]: http://aredko.blogspot.com/2013/06/easy-messaging-with-stomp-over.html?showComment=1375392256803#c2586418233658459969
[icon_delete13.gif 4]: http://www.blogger.com/delete-comment.g?blogID=8745745886722714957&postID=2586418233658459969
[Zaw Min Tun_christian posta]: http://www.blogger.com/profile/08259915055497155298
[March 25_ 2014 at 8_36 PM]: http://aredko.blogspot.com/2013/06/easy-messaging-with-stomp-over.html?showComment=1395804976000#c8918161657017146861
[icon_delete13.gif 5]: http://www.blogger.com/delete-comment.g?blogID=8745745886722714957&postID=8918161657017146861
[March 26_ 2014 at 10_00 AM]: http://aredko.blogspot.com/2013/06/easy-messaging-with-stomp-over.html?showComment=1395853207551#c1820460064188535443
[icon_delete13.gif 6]: http://www.blogger.com/delete-comment.g?blogID=8745745886722714957&postID=1820460064188535443
[Post a Comment]: http://www.blogger.com/comment.g?blogID=8745745886722714957&postID=8175059268983332216
[Newer Post]: http://aredko.blogspot.com/2013/07/easy-messaging-with-stomp-over.html
[Older Post]: http://aredko.blogspot.com/2013/05/real-time-charts-with-play-framework.html
[Post Comments _Atom]: http://aredko.blogspot.com/feeds/8175059268983332216/comments/default