Connecting RabbitMQ with Java Actors

[harish...@gmail.com]

Hi,
I have an akka actor-java based application. I need to consume RabbitMQ messages in akka java actors. Is there a library I can use?

Thanks.

[Guido Medina]

As far as my experience with RabbitMQ goes they provide which will start a loop thread and a handler function should be specified.

RMQ Java client: https://www.rabbitmq.com/java-client.html

Your handler function will just forward the message to your intended actor, and your handler should have a reference to the RMQ client so when your actor stops your handler also stops (Life-cycle)

The only challenge there you will face is if you implement some sort of ack.

Anyway when I google "akka rmq" I found this http://www.lightbend.com/activator/template/rabbitmq-akka-stream among other interesting projects.

HTH,

Guido.

[Guido Medina]

Correction of previous response: As far as my experience with RabbitMQ goes they provide a client which will start a loop thread and a handler function should be specified.

[harish...@gmail.com]

Thank you.

[Pierre]

There is also this: https://github.com/sstone/amqp-client

[tigerfoot]

This is an Akka streams example but I have a simple project here:  https://github.com/gzoller/LateRabbit

In addition to providing a RabbitMQ source for streams, this project allows you to late-acknowledge messages you pull off the queue, which is a nice feature for streams.

[ashutos...@games24x7.com]

Hi TigerFoot,

Thing is all these git projects are written in scala. And I also have  the similar use case. Was looking for a client b/c this is fairly general use case.
Or I think the handler is the only way in AkkaJava.

Please share your comments....

Thanks and Regards,
Ashutosh Prakash Mishra.