There are 4 queues set up - Queue1 to Queue4.
There are 2 topic routings, one which works and one which does not:<compositeTopic name="WorkingTopic" forwardOnly="false">
<forwardTo>
<queue physicalName="Queue1" />
<queue physicalName="Queue2" />
<queue physicalName="Queue3" />
<queue physicalName="Queue4" />
</forwardTo>
</compositeTopic><compositeTopic name="FailingTopic" forwardOnly="false" concurrentSend="true" >
<forwardTo>
<queue physicalName="Queue1" />
<queue physicalName="Queue2" />
<queue physicalName="Queue3" />
<queue physicalName="Queue4" />
</forwardTo>
</compositeTopic>Using the web console or a producer as you prefer, try to send 1k messages to WorkingTopic and you can see all 1k written to each of the 4 queues. Attempt to do the same to FailingTopic, and the broker will shut itself down after writing a few messages.The exception below is logged,2015-07-29 12:35:36,039 | INFO | ception handler. | DefaultIOExceptionHandler | q.util.DefaultIOExceptionHandler 165 | 171 - org.apache.activemq.activemq-osgi - 5.11.0.redhat-620133 | Stopping BrokerService[amq]due to exception, java.io.IOException
java.io.IOException
at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:39)[171:org.apache.activemq.activemq-osgi:5.11.0.redhat-620133]
at org.apache.activemq.leveldb.LevelDBClient.might_fail(LevelDBClient.scala:552)[171:org.apache.activemq.activemq-osgi:5.11.0.redhat-620133]
at org.apache.activemq.leveldb.LevelDBClient.might_fail_using_index(LevelDBClient.scala:1044)[171:org.apache.activemq.activemq-osgi:5.11.0.redhat-620133]
at org.apache.activemq.leveldb.LevelDBClient.store(LevelDBClient.scala:1390)[171:org.apache.activemq.activemq-osgi:5.11.0.redhat-620133]
at org.apache.activemq.leveldb.DBManager$$anonfun$drainFlushes$1.apply$mcV$sp(DBManager.scala:627)[171:org.apache.activemq.activemq-osgi:5.11.0.redhat-620133]
at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:330)[171:org.apache.activemq.activemq-osgi:5.11.0.redhat-620133]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_71]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_71]
at java.lang.Thread.run(Thread.java:745)[:1.7.0_71]
Caused by: java.lang.NullPointerException
at org.apache.activemq.leveldb.LevelDBClient$$anonfun$write_uows$1$$anonfun$apply$28$$anonfun$apply$30.apply(LevelDBClient.scala:1481)[171:org.apache.activemq.activemq-osgi:5.11.0.redhat-620133]
at org.apache.activemq.leveldb.LevelDBClient$$anonfun$write_uows$1$$anonfun$apply$28$$anonfun$apply$30.apply(LevelDBClient.scala:1460)[171:org.apache.activemq.activemq-osgi:5.11.0.redhat-620133]
at scala.collection.immutable.List.foreach(List.scala:383)[181:org.scala-lang.scala-library:2.11.0.v20140415-163722-cac6383e66]
at scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:35)[181:org.scala-lang.scala-library:2.11.0.v20140415-163722-cac6383e66]