From 16c3469878bfa844d1acde87a683466612a21807 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kimmo=20Bjo=CC=88rnsson?= Date: Fri, 16 Mar 2012 23:36:38 +0100 Subject: [PATCH 1/3] added method to send byteArray-message --- .gitignore | 5 ++++- RabbitmqGrailsPlugin.groovy | 2 +- .../org/grails/rabbitmq/RabbitDynamicMethods.groovy | 11 +++++++++++ 3 files changed, 16 insertions(+), 2 deletions(-) diff --git a/.gitignore b/.gitignore index d08fe4e..c30a425 100644 --- a/.gitignore +++ b/.gitignore @@ -4,4 +4,7 @@ plugin.xml grails-rabbitmq-*.zip* target web-app/WEB-INF/classes/ - +.idea/ +*.iml +web-app/WEB-INF/tld/c.tld +web-app/WEB-INF/tld/fmt.tld diff --git a/RabbitmqGrailsPlugin.groovy b/RabbitmqGrailsPlugin.groovy index 3e4a955..ddb8030 100644 --- a/RabbitmqGrailsPlugin.groovy +++ b/RabbitmqGrailsPlugin.groovy @@ -15,7 +15,7 @@ import org.grails.rabbitmq.RabbitConfigurationHolder class RabbitmqGrailsPlugin { // the plugin version - def version = "0.4-SNAPSHOT" + def version = "BON-0.4-SNAPSHOT" // the version or versions of Grails the plugin is designed for def grailsVersion = "1.2 > *" // the other plugins this plugin depends on diff --git a/src/groovy/org/grails/rabbitmq/RabbitDynamicMethods.groovy b/src/groovy/org/grails/rabbitmq/RabbitDynamicMethods.groovy index a19a20c..231d057 100644 --- a/src/groovy/org/grails/rabbitmq/RabbitDynamicMethods.groovy +++ b/src/groovy/org/grails/rabbitmq/RabbitDynamicMethods.groovy @@ -3,6 +3,7 @@ package org.grails.rabbitmq import org.springframework.amqp.core.Address import org.springframework.amqp.core.Message import org.springframework.amqp.core.MessagePostProcessor +import org.springframework.amqp.core.MessageProperties /** * Class for applying the dynamic rabbitSend() and rabbitRpcSend() methods to @@ -12,6 +13,7 @@ class RabbitDynamicMethods { static void applyAllMethods(target, ctx) { applyRabbitSend(target, ctx) + applyRabbitSendByteArray(target, ctx) // applyRabbitRpcSend(target, ctx) } @@ -26,6 +28,15 @@ class RabbitDynamicMethods { } } + static void applyRabbitSendByteArray(target, ctx) { + target.metaClass.rabbitSendByteArray = { Object[] args -> + String routingKey = args[0] + MessageProperties messageProperties = new MessageProperties() + Message message = new Message(args[1], messageProperties) + ctx.rabbitTemplate.send(routingKey, message) + } + } + static void applyRabbitRpcSend(target, ctx) { target.metaClass.rabbitRpcSend = { Object[] args -> // Last argument is a reply queue name From 86fd5c9b2e10708a2f09f660f2bcca35c54bb243 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kimmo=20Bjo=CC=88rnsson?= Date: Fri, 16 Mar 2012 23:38:48 +0100 Subject: [PATCH 2/3] Revert "added method to send byteArray-message" This reverts commit 16c3469878bfa844d1acde87a683466612a21807. --- .gitignore | 5 +---- RabbitmqGrailsPlugin.groovy | 2 +- .../org/grails/rabbitmq/RabbitDynamicMethods.groovy | 11 ----------- 3 files changed, 2 insertions(+), 16 deletions(-) diff --git a/.gitignore b/.gitignore index c30a425..d08fe4e 100644 --- a/.gitignore +++ b/.gitignore @@ -4,7 +4,4 @@ plugin.xml grails-rabbitmq-*.zip* target web-app/WEB-INF/classes/ -.idea/ -*.iml -web-app/WEB-INF/tld/c.tld -web-app/WEB-INF/tld/fmt.tld + diff --git a/RabbitmqGrailsPlugin.groovy b/RabbitmqGrailsPlugin.groovy index ddb8030..3e4a955 100644 --- a/RabbitmqGrailsPlugin.groovy +++ b/RabbitmqGrailsPlugin.groovy @@ -15,7 +15,7 @@ import org.grails.rabbitmq.RabbitConfigurationHolder class RabbitmqGrailsPlugin { // the plugin version - def version = "BON-0.4-SNAPSHOT" + def version = "0.4-SNAPSHOT" // the version or versions of Grails the plugin is designed for def grailsVersion = "1.2 > *" // the other plugins this plugin depends on diff --git a/src/groovy/org/grails/rabbitmq/RabbitDynamicMethods.groovy b/src/groovy/org/grails/rabbitmq/RabbitDynamicMethods.groovy index 231d057..a19a20c 100644 --- a/src/groovy/org/grails/rabbitmq/RabbitDynamicMethods.groovy +++ b/src/groovy/org/grails/rabbitmq/RabbitDynamicMethods.groovy @@ -3,7 +3,6 @@ package org.grails.rabbitmq import org.springframework.amqp.core.Address import org.springframework.amqp.core.Message import org.springframework.amqp.core.MessagePostProcessor -import org.springframework.amqp.core.MessageProperties /** * Class for applying the dynamic rabbitSend() and rabbitRpcSend() methods to @@ -13,7 +12,6 @@ class RabbitDynamicMethods { static void applyAllMethods(target, ctx) { applyRabbitSend(target, ctx) - applyRabbitSendByteArray(target, ctx) // applyRabbitRpcSend(target, ctx) } @@ -28,15 +26,6 @@ class RabbitDynamicMethods { } } - static void applyRabbitSendByteArray(target, ctx) { - target.metaClass.rabbitSendByteArray = { Object[] args -> - String routingKey = args[0] - MessageProperties messageProperties = new MessageProperties() - Message message = new Message(args[1], messageProperties) - ctx.rabbitTemplate.send(routingKey, message) - } - } - static void applyRabbitRpcSend(target, ctx) { target.metaClass.rabbitRpcSend = { Object[] args -> // Last argument is a reply queue name From 56149dfc169eb72180960507948ac6812e371b40 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kimmo=20Bjo=CC=88rnsson?= Date: Fri, 16 Mar 2012 23:40:48 +0100 Subject: [PATCH 3/3] added method to send byte-array --- .../org/grails/rabbitmq/RabbitDynamicMethods.groovy | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/src/groovy/org/grails/rabbitmq/RabbitDynamicMethods.groovy b/src/groovy/org/grails/rabbitmq/RabbitDynamicMethods.groovy index a19a20c..231d057 100644 --- a/src/groovy/org/grails/rabbitmq/RabbitDynamicMethods.groovy +++ b/src/groovy/org/grails/rabbitmq/RabbitDynamicMethods.groovy @@ -3,6 +3,7 @@ package org.grails.rabbitmq import org.springframework.amqp.core.Address import org.springframework.amqp.core.Message import org.springframework.amqp.core.MessagePostProcessor +import org.springframework.amqp.core.MessageProperties /** * Class for applying the dynamic rabbitSend() and rabbitRpcSend() methods to @@ -12,6 +13,7 @@ class RabbitDynamicMethods { static void applyAllMethods(target, ctx) { applyRabbitSend(target, ctx) + applyRabbitSendByteArray(target, ctx) // applyRabbitRpcSend(target, ctx) } @@ -26,6 +28,15 @@ class RabbitDynamicMethods { } } + static void applyRabbitSendByteArray(target, ctx) { + target.metaClass.rabbitSendByteArray = { Object[] args -> + String routingKey = args[0] + MessageProperties messageProperties = new MessageProperties() + Message message = new Message(args[1], messageProperties) + ctx.rabbitTemplate.send(routingKey, message) + } + } + static void applyRabbitRpcSend(target, ctx) { target.metaClass.rabbitRpcSend = { Object[] args -> // Last argument is a reply queue name