Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Refactore backend handling and keep now a timetamp for the last MBean…
… change.
- Loading branch information
Showing
12 changed files
with
531 additions
and
203 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
149 changes: 149 additions & 0 deletions
149
agent/core/src/main/java/org/jolokia/backend/MBeanServers.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,149 @@ | ||
| package org.jolokia.backend; | ||
|
|
||
| import java.lang.management.ManagementFactory; | ||
| import java.util.*; | ||
|
|
||
| import javax.management.*; | ||
|
|
||
| import org.jolokia.detector.ServerDetector; | ||
| import org.jolokia.util.JmxUtil; | ||
| import org.jolokia.util.ServersInfo; | ||
|
|
||
| import static javax.management.MBeanServerNotification.REGISTRATION_NOTIFICATION; | ||
| import static javax.management.MBeanServerNotification.UNREGISTRATION_NOTIFICATION; | ||
|
|
||
| /** | ||
| * Class managing the set of available MBeanServers | ||
| */ | ||
| class MBeanServers implements NotificationListener { | ||
|
|
||
| // All detected MBeanServces | ||
| private final Set<MBeanServerConnection> detectedMBeanServers; | ||
|
|
||
| // detectedMBeanServers + JolokiaMBeanServer (if available) | ||
| private final Set<MBeanServerConnection> allMBeanServers; | ||
|
|
||
| // Notification listener to register to the JolokiaMBean server | ||
| // which listens for MBean registration events | ||
| private final NotificationListener jolokiaMBeanServerListener; | ||
|
|
||
| // Private Jolokia MBeanServer | ||
| private MBeanServerConnection jolokiaMBeanServer; | ||
|
|
||
| private static final ObjectName JOLOKIA_MBEAN_SERVER_ONAME = JmxUtil.newObjectName("jolokia:type=MBeanServer"); | ||
|
|
||
| /** | ||
| * Constructor building up the list of available MBeanServers | ||
| * | ||
| * @param pDetectors detectors to be used for looking up MBeanServers | ||
| * @param pListener listener to register to the Jolokia MBeanServer when this server | ||
| * comes in late | ||
| */ | ||
| MBeanServers(List<ServerDetector> pDetectors, NotificationListener pListener) { | ||
| detectedMBeanServers = new LinkedHashSet<MBeanServerConnection>(); | ||
| jolokiaMBeanServerListener = pListener; | ||
| // Create and add our own JolokiaMBeanServer first and | ||
| // add us for registration/deregestration of the MBeanServer | ||
| jolokiaMBeanServer = lookupJolokiaMBeanServer(); | ||
| addJolokiaMBeanServerRegistrationListener(); | ||
|
|
||
| // Let every detector add its own MBeanServer | ||
| for (ServerDetector detector : pDetectors) { | ||
| detector.addMBeanServers(detectedMBeanServers); | ||
| } | ||
|
|
||
| // All MBean Server known by the MBeanServerFactory | ||
| List<MBeanServer> beanServers = MBeanServerFactory.findMBeanServer(null); | ||
| if (beanServers != null) { | ||
| detectedMBeanServers.addAll(beanServers); | ||
| } | ||
|
|
||
| // Last entry is always the platform MBeanServer | ||
| detectedMBeanServers.add(ManagementFactory.getPlatformMBeanServer()); | ||
|
|
||
| allMBeanServers = new LinkedHashSet<MBeanServerConnection>(); | ||
| if (jolokiaMBeanServer != null) { | ||
| allMBeanServers.add(jolokiaMBeanServer); | ||
| } | ||
| allMBeanServers.addAll(detectedMBeanServers); | ||
| } | ||
|
|
||
| /** | ||
| * Fetch Jolokia MBeanServer when it gets registered, remove it if being unregistered | ||
| * | ||
| * @param notification notification emitted | ||
| * @param handback not used here | ||
| */ | ||
| public synchronized void handleNotification(Notification notification, Object handback) { | ||
| String type = notification.getType(); | ||
| if (REGISTRATION_NOTIFICATION.equals(type)) { | ||
| jolokiaMBeanServer = lookupJolokiaMBeanServer(); | ||
| // We need to add the listener provided during construction time to add the Jolokia MBeanServer | ||
| // so that it is kept updated, too. | ||
| if (jolokiaMBeanServerListener != null) { | ||
| JmxUtil.addMBeanRegistrationListener(jolokiaMBeanServer, jolokiaMBeanServerListener, null); | ||
| } | ||
| } else if (UNREGISTRATION_NOTIFICATION.equals(type)) { | ||
| jolokiaMBeanServer = null; | ||
| } | ||
|
|
||
| allMBeanServers.clear(); | ||
| if (jolokiaMBeanServer != null) { | ||
| allMBeanServers.add(jolokiaMBeanServer); | ||
| } | ||
| allMBeanServers.addAll(detectedMBeanServers); | ||
| } | ||
|
|
||
| /** | ||
| * Get the list of the current set of MBeanServers which are active | ||
| * @return the list of current MBeanServers | ||
| */ | ||
| public Set<MBeanServerConnection> getMBeanServers() { | ||
| return allMBeanServers; | ||
| } | ||
|
|
||
| /** | ||
| * Return a dump information of all known MBeanServers | ||
| * | ||
| * @return information about the registered MBeanServers | ||
| */ | ||
| public String dump() { | ||
| return ServersInfo.dump(allMBeanServers); | ||
| } | ||
|
|
||
| /** | ||
| * To be called during deconstruction. | ||
| */ | ||
| public void destroy() { | ||
| MBeanServer server = ManagementFactory.getPlatformMBeanServer(); | ||
| JmxUtil.removeMBeanRegistrationListener(server,this); | ||
| } | ||
|
|
||
| /** | ||
| * Get the Jolokia MBean server | ||
| * @return Jolokia MBeanServer or null | ||
| */ | ||
| public MBeanServerConnection getJolokiaMBeanServer() { | ||
| return jolokiaMBeanServer; | ||
| } | ||
|
|
||
| // ====================================================================================================== | ||
|
|
||
| // Check, whether the Jolokia MBean Server is available and return it. | ||
| private MBeanServer lookupJolokiaMBeanServer() { | ||
| MBeanServer server = ManagementFactory.getPlatformMBeanServer(); | ||
| try { | ||
| return server.isRegistered(JOLOKIA_MBEAN_SERVER_ONAME) ? | ||
| (MBeanServer) server.getAttribute(JOLOKIA_MBEAN_SERVER_ONAME, "JolokiaMBeanServer") : | ||
| null; | ||
| } catch (JMException e) { | ||
| throw new IllegalStateException("Internal: Cannot get Jolokia MBeanServer via JMX lookup: " + e, e); | ||
| } | ||
| } | ||
|
|
||
| // Register this executor as notification listener for the JolokiaMBeanServer at the PlatformMBeanServer | ||
| private void addJolokiaMBeanServerRegistrationListener() { | ||
| MBeanServer server = ManagementFactory.getPlatformMBeanServer(); | ||
| JmxUtil.addMBeanRegistrationListener(server,this,JOLOKIA_MBEAN_SERVER_ONAME); | ||
| } | ||
| } |
Oops, something went wrong.