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

[jboss-cvs-commits at lists.jboss.org]

Author: jmesnil
Date: 2009-05-28 08:31:04 -0400 (Thu, 28 May 2009)
New Revision: 7092

Modified:
   trunk/src/main/org/jboss/messaging/core/management/impl/ManagementServiceImpl.java
Log:
management notifications

* local NotificationListener are always notified
* do not send notifications *messages* unless the server
  is fully started


Modified: trunk/src/main/org/jboss/messaging/core/management/impl/ManagementServiceImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/impl/ManagementServiceImpl.java	2009-05-28 12:29:28 UTC (rev 7091)
+++ trunk/src/main/org/jboss/messaging/core/management/impl/ManagementServiceImpl.java	2009-05-28 12:31:04 UTC (rev 7092)
@@ -109,6 +109,8 @@
 
    private StorageManager storageManager;
 
+   private MessagingServer messagingServer;
+
    private HierarchicalRepository<Set<Role>> securityRepository;
 
    private HierarchicalRepository<AddressSettings> addressSettingsRepository;
@@ -183,7 +185,8 @@
       this.addressSettingsRepository = addressSettingsRepository;
       this.securityRepository = securityRepository;
       this.storageManager = storageManager;
-
+      this.messagingServer = messagingServer;
+      
       messagingServerControl = new MessagingServerControl(postOffice,
                                                           configuration,
                                                           resourceManager,
@@ -596,7 +599,11 @@
                   }
                }
 
-               // Now send message
+               // start sending notification *messages* only when the server if fully started
+               if (messagingServer != null && !messagingServer.isStarted())
+               {
+                  return;
+               }
 
                ServerMessage notificationMessage = new ServerMessageImpl(storageManager.generateUniqueID());