Hi Sam,
I don't know a way by using the akka-camel consumer, but you can get to
camel via the CamelExtension.
1. val camel = CamelExtension(system)
2. val consumerTemplate = camel.context.createConsumerTemplate()
3. val message =
camel.context.createConsumerTemplate().receiveNoWait("activemq:youQueue")
4. if(message == null) // no message
5. else //message
This will consume one message if there is any. Create a scheduler to
perform this every 5 seconds. I haven't tried this could, but this is what
I would try.
Cheers,
Jeroen
Op donderdag 15 mei 2014 17:06:16 UTC+2 schreef Sam Starling:
>
> Hello,
>
> Is it at all possible to get an akka.camel.Consumer to consume a single
> message periodically?
>
> The code in the link below consumes all messages from a queue as quickly
> as possible, whereas I'd like to consume them at a particular rate (eg. one
> every 5 seconds) and have them left in ActiveMQ's queue until the last
> possible moment.
>
> https://gist.github.com/samstarling/1e228fe6c42468aba0f7
>
> I was thinking of getting the Consumer to consume a single message, and
> scheduling this using Akka.scheduler.repeat, but I'm open to other options
> as well.
>
> Thanks,
> Sam
>
--
>>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
