Examples of javax.management.MBeanServer.addNotificationListener()

javax.management.MBeanServer.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

      server.removeNotificationListener(broadcasterName, listenerName, null, "handback1");
      server.unregisterMBean(broadcasterName);


      Broadcaster broadcaster = new Broadcaster();
      server.registerMBean(broadcaster, broadcasterName);
      server.addNotificationListener(broadcasterName, listenerName, null, "handback2");
    
      // force notification
      broadcaster.doSomething();
      assertTrue("Listener should get a notification", listener.count == 1);
      assertTrue("Source should be the broadcaster", listener.source.equals(broadcasterName));

View Full Code Here

      ObjectName broadcasterName = new ObjectName("test:type=broadcaster");
      Broadcaster broadcaster = new Broadcaster();
      server.registerMBean(broadcaster, broadcasterName);
      
      // Add the listener
      server.addNotificationListener(broadcasterName, listenerName1, null, null);


      // Test we get a notification
      broadcaster.doSomething();
      assertEquals(1, listener1.count);
      assertEquals(broadcasterName, listener1.source);

View Full Code Here

      ObjectName broadcasterName = new ObjectName("test:type=broadcaster");
      Broadcaster broadcaster = new Broadcaster();
      server.registerMBean(broadcaster, broadcasterName);
      
      // Add the listener to the broadcaster
      server.addNotificationListener(broadcasterName, listenerName1, null, null);
      
      // Add the listener to the delegate
      ObjectName delegateName =
         new ObjectName("JMImplementation:type=MBeanServerDelegate");
      server.addNotificationListener(delegateName,listenerName1, null, null);

View Full Code Here

      server.addNotificationListener(broadcasterName, listenerName1, null, null);
      
      // Add the listener to the delegate
      ObjectName delegateName =
         new ObjectName("JMImplementation:type=MBeanServerDelegate");
      server.addNotificationListener(delegateName,listenerName1, null, null);       


      // Test we get a notification from the broadcaster
      broadcaster.doSomething();
      assertEquals(1, listener1.count);
      assertEquals(broadcasterName, listener1.source);

View Full Code Here

      ObjectName broadcasterName = new ObjectName("test:type=broadcaster");
      Broadcaster broadcaster = new Broadcaster();
      server.registerMBean(broadcaster, broadcasterName);
      
      // Add the listener to the broadcaster
      server.addNotificationListener(broadcasterName, listenerName1, null, null);
      
      // Add the listener to the delegate
      ObjectName delegateName =
         new ObjectName("JMImplementation:type=MBeanServerDelegate");
      server.addNotificationListener(delegateName,listenerName1, null, null);

View Full Code Here

      server.addNotificationListener(broadcasterName, listenerName1, null, null);
      
      // Add the listener to the delegate
      ObjectName delegateName =
         new ObjectName("JMImplementation:type=MBeanServerDelegate");
      server.addNotificationListener(delegateName,listenerName1, null, null);       


      // Remove ourselves from the broadcaster
      server.removeNotificationListener(broadcasterName, listener1);       


      // Test we get a notification from the broadcaster

View Full Code Here


          ObjectName listenerName = getObjectName();


          MBeanServer server = Jmx.getMBeanServer();


          server.addNotificationListener(mbeanName, listenerName,
                                         _filter, _handback);


        }
        else
          throw new ConfigException(L.l("mbean name is required"));

View Full Code Here

      ObjectName serviceName = new ObjectName("examples", "mbean", "legacy");
      DynamicLegacyService dynamicService = new DynamicLegacyService(legacyService);
      server.registerMBean(dynamicService, serviceName);


      // Now register a listener: we want to be able to know when the service starts and stops
      server.addNotificationListener(serviceName, new NotificationListener()
      {
         public void handleNotification(Notification notification, Object handback)
         {
            System.out.println(notification);
         }

View Full Code Here

        GCInspector inspector = new GCInspector();
        MBeanServer server = ManagementFactory.getPlatformMBeanServer();
        ObjectName gcName = new ObjectName(ManagementFactory.GARBAGE_COLLECTOR_MXBEAN_DOMAIN_TYPE + ",*");
        for (ObjectName name : server.queryNames(gcName, null))
        {
            server.addNotificationListener(name, inspector, null, null);
        }
    }


    public void handleNotification(Notification notification, Object handback)
    {

View Full Code Here

      try
      {
         MBeanServer server = MBeanServerFactory.newMBeanServer();


         DelegateListener listener = new DelegateListener();
         server.addNotificationListener(delegateName, listener, null, null);


         BuilderTest test = new BuilderTest();
         server.registerMBean(test, name);


         assertTrue("Delegate replaced", listener.userData.equals("replaced"));

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.