History

Justin Bertram b77cdaf773 ARTEMIS-1562 Refactor example documentation This commit contains these changes: * Change example documentation to use markdown * Generate HTML doc based on markdown during release * Fix XML formatting in some examples * Repair out-of-date documentation		2017-12-15 14:54:16 +00:00
..
src/main	ARTEMIS-1562 Refactor example documentation	2017-12-15 14:54:16 +00:00
pom.xml	ARTEMIS-1562 Refactor example documentation	2017-12-15 14:54:16 +00:00
readme.md	ARTEMIS-1562 Refactor example documentation	2017-12-15 14:54:16 +00:00

readme.md

JMS Clustered Grouping Example

To run the example, simply type mvn verify from this directory, or mvn -PnoServer verify if you want to start and create the broker manually.

This example demonstrates how to ensure strict ordering across a cluster using clustered message grouping

We create 3 nodes each with a grouping message handler, one with a Local handler and 2 with a Remote handler.

The local handler acts as an arbitrator for the 2 remote handlers, holding the information on routes and communicating the routing info with the remote handlers on the other 2 nodes

We then send some messages to each node with the same group id set and ensure the same consumer receives all of them

Here's the relevant snippet from the broker configuration that has the local handler

<cluster-connections>
   <cluster-connection name="my-cluster">
      <connector-ref>netty-connector</connector-ref>
      <retry-interval>500</retry-interval>
      <use-duplicate-detection>true</use-duplicate-detection>
      <message-load-balancing>STRICT</message-load-balancing>
      <max-hops>1</max-hops>
      <discovery-group-ref discovery-group-name="my-discovery-group"/>
   </cluster-connection>
</cluster-connections>

<grouping-handler name="my-grouping-handler">
   <type>LOCAL</type>
   <address>jms</address>
   <timeout>5000</timeout>
</grouping-handler>

Here's the relevant snippet from the broker configuration that has the remote handlers

<cluster-connections>
   <cluster-connection name="my-cluster">
      <retry-interval>500</retry-interval>
      <use-duplicate-detection>true</use-duplicate-detection>
      <message-load-balancing>STRICT</message-load-balancing>
      <max-hops>1</max-hops>
      <discovery-group-ref discovery-group-name="my-discovery-group"/>
   </cluster-connection>
</cluster-connections>

<grouping-handler name="my-grouping-handler">
   <type>REMOTE</type>
   <address>jms</address>
   <timeout>5000</timeout>
</grouping-handler>