[jboss-cvs] JBoss Messaging SVN: r5861 - trunk/src/main/org/jboss/messaging/core/server/impl.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Fri Feb 13 12:09:05 EST 2009


Author: jmesnil
Date: 2009-02-13 12:09:05 -0500 (Fri, 13 Feb 2009)
New Revision: 5861

Modified:
   trunk/src/main/org/jboss/messaging/core/server/impl/MessagingServerImpl.java
Log:
create the management notification address before adding other destinations so that notifications can be routed to the notification address

Modified: trunk/src/main/org/jboss/messaging/core/server/impl/MessagingServerImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/server/impl/MessagingServerImpl.java	2009-02-13 15:03:51 UTC (rev 5860)
+++ trunk/src/main/org/jboss/messaging/core/server/impl/MessagingServerImpl.java	2009-02-13 17:09:05 UTC (rev 5861)
@@ -276,6 +276,13 @@
 
       storageManager.loadBindingJournal(queueBindingInfos, destinations);
 
+      // FIXME the destination corresponding to the notification address is always created
+      // so that queues can be created wether the address is allowable or not (to revisit later)
+      if (!postOffice.containsDestination(configuration.getManagementNotificationAddress()))
+      {
+         postOffice.addDestination(configuration.getManagementNotificationAddress(), true);
+      }
+
       // Destinations must be added first to ensure flow controllers exist
       // before queues are created
       for (SimpleString destination : destinations)
@@ -331,13 +338,6 @@
 
       resourceManager.start();
 
-      // FIXME the destination corresponding to the notification address is always created
-      // so that queues can be created wether the address is allowable or not (to revisit later)
-      if (!postOffice.containsDestination(configuration.getManagementNotificationAddress()))
-      {
-         postOffice.addDestination(configuration.getManagementNotificationAddress(), true);
-      }
-
       // Deploy any pre-defined queues
       deployQueues();
 




More information about the jboss-cvs-commits mailing list