Examples of org.hornetq.api.core.management.NotificationType

org.hornetq.api.core.management.NotificationType
Types of notification emitted by HornetQ servers.
These notifications can be received through:
- JMX' MBeans subscriptions
- Core messages to a notification address (default value is {@code hornetq.notifications})
- JMS messages
@see the HornetQ user manual section on "Management Notifications" @author Jeff Mesnil

      {
         log.trace("Receiving notification : " + notification + " on server " + this.server);
      }
      synchronized (notificationLock)
      {
         NotificationType type = notification.getType();


         switch (type)
         {
            case BINDING_ADDED:
            {

View Full Code Here


            // TODO - optimised this by just passing int in header - but filter needs to be extended to support IN with
            // a list of integers
            SimpleString type = message.getSimpleStringProperty(ManagementHelper.HDR_NOTIFICATION_TYPE);


            NotificationType ntype = NotificationType.valueOf(type.toString());


            switch (ntype)
            {
               case BINDING_ADDED:
               {

View Full Code Here

      {
         log.trace("Receiving notification : " + notification + " on server " + this.server);
      }
      synchronized (notificationLock)
      {
         NotificationType type = notification.getType();


         switch (type)
         {
            case BINDING_ADDED:
            {

View Full Code Here


            // TODO - optimised this by just passing int in header - but filter needs to be extended to support IN with
            // a list of integers
            SimpleString type = message.getSimpleStringProperty(ManagementHelper.HDR_NOTIFICATION_TYPE);


            NotificationType ntype = NotificationType.valueOf(type.toString());


            switch (ntype)
            {
               case BINDING_ADDED:
               {

View Full Code Here

   }


   @Override
   public void onNotification(Notification notification)
   {
      NotificationType type = notification.getType();


      switch (type)
      {
         case BINDING_ADDED:
         {

View Full Code Here

      {
         HornetQServerLogger.LOGGER.trace("Receiving notification : " + notification + " on server " + this.server);
      }
      synchronized (notificationLock)
      {
         NotificationType type = notification.getType();


         switch (type)
         {
            case BINDING_ADDED:
            {

View Full Code Here


            // TODO - optimised this by just passing int in header - but filter needs to be extended to support IN with
            // a list of integers
            SimpleString type = message.getSimpleStringProperty(ManagementHelper.HDR_NOTIFICATION_TYPE);


            NotificationType ntype = NotificationType.valueOf(type.toString());


            switch (ntype)
            {
               case BINDING_ADDED:
               {

View Full Code Here

   }


   @Override
   public void onNotification(Notification notification)
   {
      NotificationType type = notification.getType();


      switch (type)
      {
         case BINDING_ADDED:
         {

View Full Code Here


            // TODO - optimised this by just passing int in header - but filter needs to be extended to support IN with
            // a list of integers
            SimpleString type = message.getSimpleStringProperty(ManagementHelper.HDR_NOTIFICATION_TYPE);


            NotificationType ntype = NotificationType.valueOf(type.toString());


            switch (ntype)
            {
               case BINDING_ADDED:
               {

View Full Code Here

      {
         HornetQServerLogger.LOGGER.trace("Receiving notification : " + notification + " on server " + this.server);
      }
      synchronized (notificationLock)
      {
         NotificationType type = notification.getType();


         switch (type)
         {
            case BINDING_ADDED:
            {

View Full Code Here

0 1 2 3 4 5 6 7

TOP

Related Classes of org.hornetq.api.core.management.NotificationType

org.hornetq.core.postoffice.impl.PostOfficeImpl

org.hornetq.core.protocol.stomp.StompProtocolManager

org.hornetq.core.server.cluster.impl.ClusterConnectionImpl$MessageFlowRecordImpl

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.