Examples of javax.management.MBeanServerConnection.addNotificationListener()

Class javax.management.MBeanServerConnection

Examples of javax.management.MBeanServerConnection.addNotificationListener()

javax.management.MBeanServerConnection.addNotificationListener()
Add a notification listener to an MBean. @param name the name of the MBean broadcasting notifications @param listener the listener to add @param filter a filter to preprocess notifications @param handback a object to add to any notifications @exception InstanceNotFoundException if the broadcaster is not registered @exception IOException for a communication problem during this operation

         }


         // Non-serializable handback
         try
         {
            mbsc.addNotificationListener(emitterName, listenerName, null, new Object());
            fail();
         } catch (IOException x)
         {
         }

View Full Code Here

         }


         // Non-serializable filter and non serializable handback
         try
         {
            mbsc.addNotificationListener(emitterName, listenerName, new NotificationFilter()
            {
               public boolean isNotificationEnabled(Notification notification)
               {
                  return false;
               }

View Full Code Here

         // Everything is serializable
         ObjectName name = ObjectName.getInstance(":mbean=dummy");
         MBeanServerNotificationFilter filter = new MBeanServerNotificationFilter();
         filter.disableObjectName(name);
         Object handback = new Integer(13);
         mbsc.addNotificationListener(emitterName, listenerName, filter, handback);


         // Wait for notifications threads to start
         sleep(1000);


         Notification notification = new MBeanServerNotification(MBeanServerNotification.REGISTRATION_NOTIFICATION, this, 0, name);

View Full Code Here


         // Disable filtering
         filter.enableAllObjectNames();
         // Remove and readd: on server side there is a serialized copy of the filter
         mbsc.removeNotificationListener(emitterName, listenerName);
         mbsc.addNotificationListener(emitterName, listenerName, filter, handback);


         // Wait for notifications threads to start
         sleep(1000);


         emitter.emit(notification);

View Full Code Here

            public boolean isNotificationEnabled(Notification notification)
            {
               return enable.get();
            }
         };
         mbsc.addNotificationListener(emitterName, listener, filter, null);


         // Wait for notification threads to start
         sleep(1000);


         String type = "notification.type";

View Full Code Here

         cntor = JMXConnectorFactory.connect(cntorServer.getAddress(), getEnvironment());
         MBeanServerConnection mbsc = cntor.getMBeanServerConnection();


         // Non-serializable handback, should stay on client side
         Object handback = new Object();
         mbsc.addNotificationListener(emitterName, listener, null, handback);


         // Wait for notification threads to start
         sleep(1000);


         String type = "notification.type";

View Full Code Here

         MBeanServerConnection mbsc = cntor.getMBeanServerConnection();


         String type = "notification.type";


         // First listener
         mbsc.addNotificationListener(emitterName, listener1, null, null);
         // Second listener
         NotificationFilterSupport filter = new NotificationFilterSupport();
         filter.enableType(type);
         mbsc.addNotificationListener(emitterName, listener1, filter, null);
         // Third listener

View Full Code Here

         // First listener
         mbsc.addNotificationListener(emitterName, listener1, null, null);
         // Second listener
         NotificationFilterSupport filter = new NotificationFilterSupport();
         filter.enableType(type);
         mbsc.addNotificationListener(emitterName, listener1, filter, null);
         // Third listener
         Object handback = new Object();
         mbsc.addNotificationListener(emitterName, listener1, null, handback);
         // Fourth listener
         mbsc.addNotificationListener(emitterName, listener2, null, null);

View Full Code Here

         NotificationFilterSupport filter = new NotificationFilterSupport();
         filter.enableType(type);
         mbsc.addNotificationListener(emitterName, listener1, filter, null);
         // Third listener
         Object handback = new Object();
         mbsc.addNotificationListener(emitterName, listener1, null, handback);
         // Fourth listener
         mbsc.addNotificationListener(emitterName, listener2, null, null);


         // Wait for notification threads to start
         sleep(1000);

View Full Code Here

         mbsc.addNotificationListener(emitterName, listener1, filter, null);
         // Third listener
         Object handback = new Object();
         mbsc.addNotificationListener(emitterName, listener1, null, handback);
         // Fourth listener
         mbsc.addNotificationListener(emitterName, listener2, null, null);


         // Wait for notification threads to start
         sleep(1000);


         Notification notification = new Notification(type, this, 0);

View Full Code Here

0 1 2 3 4 5

TOP

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.