changed references to the bean rabbitMQConnectionFactory to rabbitCon…

…nectionFactory.
grails-plugins · Jul 21, 2015 · c963ca4 · c963ca4
1 parent 4449c29
commit c963ca4
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 8 deletions.
diff --git a/grails-app/init/grails/plugins/rabbitmq/Application.groovy b/grails-app/init/grails/plugins/rabbitmq/Application.groovy
@@ -2,10 +2,7 @@ package grails.plugins.rabbitmq
 
 import grails.boot.GrailsApp
 import grails.boot.config.GrailsAutoConfiguration
-import org.springframework.boot.autoconfigure.EnableAutoConfiguration
-import org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration
 
-@EnableAutoConfiguration(exclude = [RabbitAutoConfiguration])
 class Application extends GrailsAutoConfiguration {
     static void main(String[] args) {
         GrailsApp.run(Application, args)

diff --git a/src/main/groovy/grails.plugins.rabbitmq/RabbitServiceConfigurer.groovy b/src/main/groovy/grails.plugins.rabbitmq/RabbitServiceConfigurer.groovy
@@ -201,7 +201,7 @@ class RabbitServiceConfigurer {
             // ready to process messages.
             autoStartup = false
             channelTransacted = isServiceTransactional()
-            connectionFactory = ref("rabbitMQConnectionFactory")
+            connectionFactory = ref("rabbitConnectionFactory")
             concurrentConsumers = serviceConcurrentConsumers
             messageListener = ref("${propertyName}RabbitAdapter")
             for (entry in containerOptions) {

diff --git a/src/main/groovy/grails.plugins.rabbitmq/RabbitmqGrailsPlugin.groovy b/src/main/groovy/grails.plugins.rabbitmq/RabbitmqGrailsPlugin.groovy
@@ -85,7 +85,7 @@ class RabbitmqGrailsPlugin extends Plugin {
             def parentClassLoader = getClass().classLoader
             def loader = new GroovyClassLoader(parentClassLoader)
             def connectionFactoryClass = loader.loadClass(connectionFactoryClassName)
-            rabbitMQConnectionFactory(connectionFactoryClass, connectionFactoryHostname) {
+            rabbitConnectionFactory(connectionFactoryClass, connectionFactoryHostname) {
                 username = connectionFactoryUsername
                 password = connectionFactoryPassword
                 channelCacheSize = connectionChannelCacheSize
@@ -99,7 +99,7 @@ class RabbitmqGrailsPlugin extends Plugin {
                 }
             }
             rabbitTemplate(RabbitTemplate) {
-                connectionFactory = rabbitMQConnectionFactory
+                connectionFactory = rabbitConnectionFactory
                 if (messageConverterBean) {
                      messageConverter = ref(messageConverterBean)
                  } else {
@@ -108,7 +108,7 @@ class RabbitmqGrailsPlugin extends Plugin {
                      messageConverter = converter
                  }
             }
-            adm(RabbitAdmin, rabbitMQConnectionFactory)
+            adm(RabbitAdmin, rabbitConnectionFactory)
             rabbitErrorHandler(RabbitErrorHandler)
 
             // Add beans to hook up services as AMQP listeners.
@@ -212,7 +212,7 @@ class RabbitmqGrailsPlugin extends Plugin {
     }
 
     private addDynamicMessageSendingMethods(classes, ctx) {
-        if(ctx.rabbitMQConnectionFactory) {
+        if(ctx.rabbitConnectionFactory) {
             classes.each { clz ->
                 RabbitDynamicMethods.applyAllMethods(clz, ctx)
             }