Package javax.management

Examples of javax.management.NotificationEmitter.addNotificationListener()

282
283
284
285
286
287
288
289
290
291
292
      NotificationEmitter proxy = (NotificationEmitter)MBeanServerInvocationHandler.newProxyInstance(server, name, NotificationEmitter.class, true);
      TestListener listener1 = new TestListener();
      TestFilter filter = new TestFilter();
      Object handback = new Object();
      proxy.addNotificationListener(listener1, filter, handback);

      TestListener listener2 = new TestListener();
      proxy.addNotificationListener(listener2, null, null);

      mbean.test();
View Full Code Here
285
286
287
288
289
290
291
292
293
294
295
      TestFilter filter = new TestFilter();
      Object handback = new Object();
      proxy.addNotificationListener(listener1, filter, handback);

      TestListener listener2 = new TestListener();
      proxy.addNotificationListener(listener2, null, null);

      mbean.test();
      if (!listener1.received) fail();
      if (!listener2.received) fail();
View Full Code Here
176
177
178
179
180
181
182
183
184
185
186
              _gc_callback -= (_gc_callback>>3);
            }
          }
          NotificationEmitter emitter = (NotificationEmitter) _allMemBean;
          emitter.addNotificationListener(this, null, m);
          ++c;
        }
      }
      assert c == 1;
    }
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
        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
188
189
190
191
192
193
194
195
196
197
198
        };
        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
55
56
57
58
59
60
61
62
63
64
65
          // just FYI
          // System.out.println("memory threshold exceeded !!! : \n "+memString());
        }
      }
    };
    emitter.addNotificationListener(l,null,null);
   
    // remove previous listeners
    for(NotificationListener n : listeners){
      try {
        emitter.removeNotificationListener(n);
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
          // just FYI
          // System.out.println("memory threshold exceeded !!! : \n "+memString());
        }
      }
    };
    emitter.addNotificationListener(l,null,null);
   
    // remove previous listeners
    for(NotificationListener n : listeners){
      try {
        emitter.removeNotificationListener(n);
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
  }

  private MemoryMonitor() {
    final MemoryMXBean mbean = ManagementFactory.getMemoryMXBean();
    NotificationEmitter emitter = (NotificationEmitter) mbean;
    emitter.addNotificationListener(new NotificationListener() {
      public void handleNotification(Notification n, Object hb) {
        if (n.getType()
            .equals(MemoryNotificationInfo.MEMORY_THRESHOLD_EXCEEDED)) {
          long maxMemory = tenuredGenPool.getUsage().getMax();
          long usedMemory = tenuredGenPool.getUsage().getUsed();
View Full Code Here
369
370
371
372
373
374
375
376
377
378
379
       
        // Test notifications
        NotificationEmitter notifyProxy = (NotificationEmitter) proxy;
        TestJMXNotificationListener listener =
                new TestJMXNotificationListener();
        notifyProxy.addNotificationListener(listener, null, null);
        // add another node
        SgsTestNode node3 = null;
        try {
            node3 = new SgsTestNode(serverNode, null, null);
            // We expect to see one notification for a started node
View Full Code Here
31
32
33
34
35
36
37
38
39
        }
       
        MemoryMXBean mbean = ManagementFactory.getMemoryMXBean();
        NotificationEmitter emitter = (NotificationEmitter) mbean;
        MemoryNotificationListener listener = new MemoryNotificationListener(types);
        emitter.addNotificationListener(listener, null, cs);
        init=true;
  }
}
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.