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.
