Package javax.management

Examples of javax.management.NotificationEmitter.addNotificationListener()

103
104
105
106
107
108
109
110
111
112
113
        super();
        final MemoryMXBean mbean = ManagementFactory.getMemoryMXBean();
        final NotificationEmitter emitter = (NotificationEmitter) mbean;

        // register with the Java5 memory management system.
        emitter.addNotificationListener(new NotificationHandler(), null, null);
    }

    /**
     * Get the <code>Logger</code>.
     *
 
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
        NotificationFilter filter = null;
        Object handback = null;
        final ScanState before;
        final NotificationEmitter emitter = (NotificationEmitter)
                makeNotificationEmitter(proxy,DirectoryScannerMXBean.class);
        emitter.addNotificationListener(listener, filter, handback);
        before = proxy.getState();
        op.call();
        try {
            final Notification notification =
                    queue.poll(3000,TimeUnit.MILLISECONDS);
View Full Code Here
189
190
191
192
193
194
195
196
197
198
199
        };
        NotificationFilter filter = null;
        Object handback = null;
        final ScanState before;
        final NotificationEmitter emitter = (NotificationEmitter)proxy;
        emitter.addNotificationListener(listener, filter, handback);
        before = proxy.getState();
        op.call();
        try {
            final Notification notification =
                    queue.poll(3000,TimeUnit.MILLISECONDS);
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
        emitter.removeNotificationListener(this, null, memoryPoolMXBean);
      } catch (Exception e) {  }
      MemoryUsage memUsage = memoryPoolMXBean.getUsage();
      if (memUsage != null) {
        if (memoryPoolMXBean.isUsageThresholdSupported()) {
          emitter.addNotificationListener(this, null, memoryPoolMXBean);
          long memUsageTreshold =
                  new Double(new Long(memUsage.getMax()).doubleValue() *
                  treshold).longValue();
          memoryPoolMXBean.setUsageThreshold(memUsageTreshold);
          log.config("Setting treshold: " + memUsageTreshold +
View Full Code Here
160
161
162
163
164
165
166
167
168
169
170
  
    void registerForMemoryThresholdNotifications() {
      MemoryMXBean memMXBean = ManagementFactory.getMemoryMXBean();
      NotificationEmitter emitter = (NotificationEmitter) memMXBean;
      emitter.addNotificationListener(this, null, null);
      for (String listener : listenersList) {
        try {
            emitter.addNotificationListener(
          (NotificationListener)Class.forName(listener).newInstance(),
          null, null);
View Full Code Here
163
164
165
166
167
168
169
170
171
172
173
      MemoryMXBean memMXBean = ManagementFactory.getMemoryMXBean();
      NotificationEmitter emitter = (NotificationEmitter) memMXBean;
      emitter.addNotificationListener(this, null, null);
      for (String listener : listenersList) {
        try {
            emitter.addNotificationListener(
          (NotificationListener)Class.forName(listener).newInstance(),
          null, null);
        } catch (Exception ex) {
                        _logger.log(Level.WARNING, " Error in loading class " + listener, ex) ;
        }
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
      NotificationEmitter emitter = (NotificationEmitter)MBeanServerInvocationHandler.newProxyInstance(server, name, LocalServiceMBean.class, true);

      try
      {
         emitter.addNotificationListener(new TestListener(), null, null);
         fail("The MBean is not a NotificationEmitter");
      }
      catch (IllegalArgumentException x)
      {
      }
View Full Code Here
222
223
224
225
226
227
228
229
230
231
232
      LocalEmitterService mbean = new LocalEmitterService();
      server.registerMBean(mbean, name);

      NotificationEmitter proxy = (NotificationEmitter)MBeanServerInvocationHandler.newProxyInstance(server, name, NotificationEmitter.class, true);
      TestListener listener = new TestListener();
      proxy.addNotificationListener(listener, null, null);
      mbean.test();
      if (!listener.received) fail();
   }

   public void testGetNotificationInfo() throws Exception
View Full Code Here
248
249
250
251
252
253
254
255
256
257
258
      LocalEmitterService mbean = new LocalEmitterService();
      server.registerMBean(mbean, name);

      NotificationEmitter proxy = (NotificationEmitter)MBeanServerInvocationHandler.newProxyInstance(server, name, NotificationEmitter.class, true);
      TestListener listener = new TestListener();
      proxy.addNotificationListener(listener, null, null);
      proxy.removeNotificationListener(listener);
      mbean.test();
      if (listener.received) fail();
   }
View Full Code Here
265
266
267
268
269
270
271
272
273
274
275
      NotificationEmitter proxy = (NotificationEmitter)MBeanServerInvocationHandler.newProxyInstance(server, name, NotificationEmitter.class, true);
      TestListener listener = new TestListener();
      TestFilter filter = new TestFilter();
      Object handback = new Object();
      proxy.addNotificationListener(listener, filter, handback);
      proxy.removeNotificationListener(listener, filter, handback);
      mbean.test();
      if (listener.received) fail();
   }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.