Hi, I'm using Apollo 1.6. I would like to consume messages from a Queue, that mirrors a Topic of the same name, with an Openwire Consumer. The incoming messages are produced from a MQTT Publisher (QoS 2).
The messages are mirrored and enqueued correctly from the Topic to the Queue, however the Openwire Consumer is unable to retrieve them (java: receive() returns null). If I produce a message with with an Openwire Producer on the Topic or the Queue however, the Consumer is able to pick it up correctly. Any ideas? P.S.: I also get assertion warnings from Apollo, but the messages seem to transmit correctly (QoS 2): java.lang.AssertionError: assertion failed: locator_based.unary_!.||(uow.have_locators) 2013-10-24 14:17:06,755 | WARN | stackref=141ea65071b java.lang.AssertionError: assertion failed: locator_based.unary_!.||(uow.have_locators) at scala.Predef$.assert(Predef.scala:179) at org.apache.activemq.apollo.broker.store.DelayingStoreSupport$$anonfun$4.apply(DelayingStoreSupport.scala:535) at org.apache.activemq.apollo.broker.store.DelayingStoreSupport$$anonfun$4.apply(DelayingStoreSupport.scala:530) at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:251) at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:251) at scala.collection.immutable.List.foreach(List.scala:309) at scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:32) at scala.collection.mutable.ListBuffer.foreach(ListBuffer.scala:45) at scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:251) at scala.collection.AbstractTraversable.flatMap(Traversable.scala:105) at org.apache.activemq.apollo.broker.store.DelayingStoreSupport$class.drain_flushes(DelayingStoreSupport.scala:530) at org.apache.activemq.apollo.broker.store.leveldb.LevelDBStore.drain_flushes(LevelDBStore.scala:47) at org.apache.activemq.apollo.broker.store.DelayingStoreSupport$$anonfun$3.apply$mcV$sp(DelayingStoreSupport.scala:516) at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:357) at org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource$1.run(HawtCustomDispatchSource.java:127) at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:96) at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77) -- View this message in context: http://activemq.2283324.n4.nabble.com/Apollo-1-6-Mirrored-Queues-MQTT-Publisher-to-Topic-Can-t-consume-from-mirrored-queue-with-Openwire-C-tp4673206.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.