Hi Ben, a JMS message on the ActiveMQ queue is consumed by the Camel ActiveMQ component and sent as a Camel message to the consumer actor.
When using autoAck false you can positively or negatively acknowledge the receipt of the Camel message, but that is not the same thing as the acknowledgement of the JMS message towards the broker. You can configure how the Camel ActiveMQ component should behave when picking JMS messages off the queue using options like acknowledgementModeName,see http://camel.apache.org/activemq.html and http://camel.apache.org/jms. Just append options to the endointUri defined in your consumer actor. /A On Friday, March 14, 2014 9:12:50 AM UTC+1, bendg25 wrote: > > Hi > > I am trying to get a sample working where messages are redeliverd every > minute until success. > > I have modified this example: > > https://github.com/cjwebb/blog-code/tree/master/akka-camel-and-actimemq > > So the consumer always sends a failure response: > > class SimpleConsumer() extends Actor with Consumer { > > def endpointUri: String = "activemq:foo.bar" > > override def autoAck = false > > def receive = { > > case msg: CamelMessage => > > println(msg) > > sender ! Failure(new Exception()) > > } > > } > > I expect to see the number of messages enqueued to increase, but the > messages are still dequeued, what is going wrong here? > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
