activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ocan <oezkan....@gmail.com>
Subject Apollo 1.6: Mirrored Queues: MQTT Publisher to Topic. Can't consume from mirrored queue with Openwire Consumer.
Date Thu, 24 Oct 2013 14:43:58 GMT
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.

Mime
View raw message