Package javax.management

Examples of javax.management.NotificationEmitter.addNotificationListener()

57
58
59
60
61
62
63
64
65
66
67
    @Override public void setASysMon(ASysMonApi sysMon) {
        this.sysMon = sysMon;

        for (GarbageCollectorMXBean gcbean : ManagementFactory.getGarbageCollectorMXBeans()) {
            final NotificationEmitter emitter = (NotificationEmitter) gcbean;
            emitter.addNotificationListener(listener, null, null);
        }
    }

    @Override public void prepareMeasurements(Map<String, Object> mementos) {
    }
View Full Code Here
146
147
148
149
150
151
152
153
154
155
156
                        }
                    }
                };

                //Add the listener
                emitter.addNotificationListener(listener, null, null);
            }
        }
    }

    private MemoryStatus findStatus(long used, long max) {
View Full Code Here
179
180
181
182
183
184
185
186
187
188
189
        };
        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
102
103
104
105
106
107
108
109
110
111
112
        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
92
93
94
95
96
97
98
99
100
101
102
   */
  private MemoryObserver() {
    MemoryMXBean mbean = ManagementFactory.getMemoryMXBean();
    NotificationEmitter emitter = (NotificationEmitter) mbean;
    listener = new MemoryNotificationListener();
    emitter.addNotificationListener(listener, null, null);
    List<MemoryPoolMXBean> pools = ManagementFactory.getMemoryPoolMXBeans();
    // activate threshhold for all those of interest
    for (MemoryPoolMXBean pool : pools) {
      // if (pool.getType() == MemoryType.HEAP) {
      if (pool.isCollectionUsageThresholdSupported()) {
View Full Code Here
146
147
148
149
150
151
152
153
154
155
156
                                                                    MeasurableMonitor.class,
                                                                    new ProcessMemoryMonitor());
        if(mMon instanceof ProcessMemoryMonitor) {
            NotificationEmitter emitter = (NotificationEmitter)((ProcessMemoryMonitor)mMon).getMXBean();
            jmxListener = new JMXNotificationListener();
            emitter.addNotificationListener(jmxListener, null, null);
        }
        return mMon;
    }

    public MeasurableMonitor getMeasurableMonitor() {
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.