Rabbit MQ as defined by rabbitmq.com is a robust messaging for applications. We used RabbitMQ to achieve asynchronous communication between two parts of the application.<\/p>\n
I would like to share the same in a step by step fashion.<\/p>\n
Here are few simple steps that I followed to make my grails application use rabbitmq:<\/strong><\/p>\n 1.Install rabbitmq : <\/strong><\/p>\n Download the installable from http:\/\/www.rabbitmq.com\/download.html. Install the same on your machine.<\/p>\n 2.Install the rabbitmq grails plugin:<\/strong><\/p>\n [java] grails install-plugin rabbitmq[\/java]<\/p>\n 3.Configure the rabbit server and a queue in the Config.groovy:<\/strong><\/p>\n [java] retryPolicy.maxAttempts = 3<\/p>\n queues = { 4.Write a method to populate messages in the queue: <\/strong> [java] 5.Write a handler Service which shall handle the messages that are put in the queue:<\/strong><\/p>\n [java] static rabbitQueue = ‘myTestQueue’ \/\/ This method gets called by the plugin whenever there is any new message in the queue. Hope this helps!!!<\/p>\n","protected":false},"excerpt":{"rendered":" Rabbit MQ as defined by rabbitmq.com is a robust messaging for applications. We used RabbitMQ to achieve asynchronous communication between two parts of the application. I would like to share the same in a step by step fashion. Here are few simple steps that I followed to make my grails application use rabbitmq: 1.Install rabbitmq […]<\/p>\n","protected":false},"author":26,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"iawp_total_views":13},"categories":[7],"tags":[1078,4840,186,1079,1077],"aioseo_notices":[],"_links":{"self":[{"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/posts\/8708"}],"collection":[{"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/users\/26"}],"replies":[{"embeddable":true,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/comments?post=8708"}],"version-history":[{"count":2,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/posts\/8708\/revisions"}],"predecessor-version":[{"id":54653,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/posts\/8708\/revisions\/54653"}],"wp:attachment":[{"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/media?parent=8708"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/categories?post=8708"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/tags?post=8708"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}
\n \/\/ grails-app\/conf\/Config.groovy
\nrabbitmq {
\n connectionfactory {
\n username = ‘guest’
\n password = ‘guest’
\n hostname = ‘localhost’
\n consumers = 5
\n }<\/p>\n
\n myTestQueue autoDelete: false, durable: true, exclusive: false
\n }
\n}
\n[\/java]<\/p>\n
\nrabbitmq plugin injects a rabbitSend() method in all the services and controllers<\/p>\n
\n\/\/This method could be defined in any service.
\npopulateQueue(){
\n rabbitSend(‘myTestQueue’, "some id:1,some action: do this")
\n \/\/ Message has to be a String
\n}
\n[\/java]<\/p>\n
\nclass QueueBasedMyTestService {<\/p>\n
\n def solrSearchService<\/p>\n
\n \/\/ We can configure n number of parallel handlers
\n void handleMessage(message){
\n log.info("Message Received ${message}")
\n \/\/ We have recieved the message from the rabbitmq server’s queue
\n }
\n}
\n[\/java]<\/p>\n