[jboss-cvs] JBoss Messaging SVN: r8566 - branches/Branch_1_4/src/main/org/jboss/jms/server.

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

Author: dgrove_redhat.com
Date: 2012-10-08 12:05:47 -0400 (Mon, 08 Oct 2012)
New Revision: 8566

Modified:
   branches/Branch_1_4/src/main/org/jboss/jms/server/MessagingClusterHealthMBean.java
Log:
JBMESSAGING-1935

Modified: branches/Branch_1_4/src/main/org/jboss/jms/server/MessagingClusterHealthMBean.java
===================================================================
--- branches/Branch_1_4/src/main/org/jboss/jms/server/MessagingClusterHealthMBean.java	2012-10-08 15:54:47 UTC (rev 8565)
+++ branches/Branch_1_4/src/main/org/jboss/jms/server/MessagingClusterHealthMBean.java	2012-10-08 16:05:47 UTC (rev 8566)
@@ -28,6 +28,7 @@
 import java.util.List;
 import java.util.Set;
 
+import javax.management.Notification;
 import javax.management.ObjectName;
 
 import org.jboss.logging.Logger;
@@ -117,6 +118,10 @@
       
       nodeRecovery.start();
       
+      Notification msg = new Notification("org.jboss.jms.server.MessagingClusterHealthMBean.stopNodeOnDBFailure", this, getNextNotificationSequenceNumber());
+      msg.setUserData(getServiceName());
+      sendNotification(msg);
+      
       log.info("JBM node is stopped.");
    }
 
@@ -233,7 +238,7 @@
          this.startService(poName);
          pm = (MessagingPostOffice)JMXAccessor.getJMXAttributeOverSecurity(server, poName, "Instance");
       }
-      
+
       List<ObjectName> copy = new ArrayList<ObjectName>(connectionFactories);
       connectionFactories.clear();
       //start cf
@@ -246,6 +251,10 @@
 
       nodeStopped = false;
       
+      Notification msg = new Notification("org.jboss.jms.server.MessagingClusterHealthMBean.restartJBMNode", this, getNextNotificationSequenceNumber());
+      msg.setUserData(getServiceName());
+      sendNotification(msg);      
+      
       log.info("JBM node restarted.");
       
       // restart message delivery to MDBs