qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ritch...@apache.org
Subject svn commit: r960541 - in /qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server: binding/BindingFactory.java queue/SimpleAMQQueue.java
Date Mon, 05 Jul 2010 11:14:10 GMT
Author: ritchiem
Date: Mon Jul  5 11:14:10 2010
New Revision: 960541

URL: http://svn.apache.org/viewvc?rev=960541&view=rev
Log:
QPID-1447 : Move Queue Reconfiguration to the Queue rather than the Binding Factory

Modified:
    qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/binding/BindingFactory.java
    qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java

Modified: qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/binding/BindingFactory.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/binding/BindingFactory.java?rev=960541&r1=960540&r2=960541&view=diff
==============================================================================
--- qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/binding/BindingFactory.java
(original)
+++ qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/binding/BindingFactory.java
Mon Jul  5 11:14:10 2010
@@ -204,14 +204,6 @@ public class BindingFactory
             getConfigStore().addConfiguredObject(b);
             b.logCreation();
 
-            //Reconfigure the queue for to reflect this new binding.
-            ConfigurationPlugin config = queue.getVirtualHost().getConfiguration().getQueueConfiguration(queue);
-
-            if (config != null)
-            {
-                // Reconfigure with new config.
-                queue.configure(config);
-            }
             return true;
         }
         else

Modified: qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java?rev=960541&r1=960540&r2=960541&view=diff
==============================================================================
--- qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
(original)
+++ qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
Mon Jul  5 11:14:10 2010
@@ -503,6 +503,15 @@ public class SimpleAMQQueue implements A
                 break;
             }
         }
+
+        //Reconfigure the queue for to reflect this new binding.
+        ConfigurationPlugin config = getVirtualHost().getConfiguration().getQueueConfiguration(this);
+
+        if (config != null)
+        {
+            // Reconfigure with new config.
+            configure(config);
+        }
     }
 
     public int getBindingCountHigh()



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message