{"id":8708,"date":"2012-09-25T23:04:08","date_gmt":"2012-09-25T17:34:08","guid":{"rendered":"http:\/\/www.tothenew.com\/blog\/?p=8708"},"modified":"2022-01-13T16:45:03","modified_gmt":"2022-01-13T11:15:03","slug":"few-simple-steps-for-integrating-rabbit-mq-with-grails","status":"publish","type":"post","link":"https:\/\/www.tothenew.com\/blog\/few-simple-steps-for-integrating-rabbit-mq-with-grails\/","title":{"rendered":"Few Simple steps for integrating Rabbit MQ with Grails"},"content":{"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.<\/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]
\n \/\/ grails-app\/conf\/Config.groovy
\nrabbitmq {
\n connectionfactory {
\n username = ‘guest’
\n password = ‘guest’
\n hostname = ‘localhost’
\n consumers = 5
\n }<\/p>\n

retryPolicy.maxAttempts = 3<\/p>\n

queues = {
\n myTestQueue autoDelete: false, durable: true, exclusive: false
\n }
\n}
\n[\/java]<\/p>\n

4.Write a method to populate messages in the queue: <\/strong>
\nrabbitmq plugin injects a rabbitSend() method in all the services and controllers<\/p>\n

[java]
\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

5.Write a handler Service which shall handle the messages that are put in the queue:<\/strong><\/p>\n

[java]
\nclass QueueBasedMyTestService {<\/p>\n

static rabbitQueue = ‘myTestQueue’
\n def solrSearchService<\/p>\n

\/\/ This method gets called by the plugin whenever there is any new message in the queue.
\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

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":26,"footnotes":""},"categories":[7],"tags":[1078,4840,186,1079,1077],"class_list":["post-8708","post","type-post","status-publish","format-standard","hentry","category-grails","tag-amqp","tag-grails","tag-jms","tag-messaging","tag-rabbitmq"],"aioseo_notices":[],"aioseo_head":"\n\t\t\n\t\n\t\n\t\n\t\n\t\n\t\t\n\t\t\n\t\t\n\t\t\n\t\t\n\t\t\n\t\t\n\t\t\n\t\t\n\t\t\n\t\t\n\t\t\n\t\t\n\t\t