From 254b046275577c97f6c8ef61b96f91b57cf5295c Mon Sep 17 00:00:00 2001 From: aph Date: Thu, 3 May 2007 18:30:33 +0000 Subject: 2007-05-03 Andrew Haley * gnu/javax/management/Server.java (Server): Record the delegate. (registerMBean): Notify the delegate. (unregisterMBean): Likewise. (notify): New method. git-svn-id: svn+ssh://gcc.gnu.org/svn/gcc/trunk@124383 138bc75d-0d04-0410-961f-82ee72b054a4 --- libjava/classpath/gnu/javax/management/Server.java | 21 +++++++++++++++++++++ 1 file changed, 21 insertions(+) (limited to 'libjava/classpath/gnu/javax') diff --git a/libjava/classpath/gnu/javax/management/Server.java b/libjava/classpath/gnu/javax/management/Server.java index aa39c75ad46..616854e95bd 100644 --- a/libjava/classpath/gnu/javax/management/Server.java +++ b/libjava/classpath/gnu/javax/management/Server.java @@ -53,6 +53,7 @@ import java.util.HashSet; import java.util.Iterator; import java.util.Map; import java.util.Set; +import java.util.concurrent.atomic.AtomicLong; import javax.management.Attribute; import javax.management.AttributeList; @@ -75,6 +76,7 @@ import javax.management.MBeanRegistration; import javax.management.MBeanRegistrationException; import javax.management.MBeanServer; import javax.management.MBeanServerDelegate; +import javax.management.MBeanServerNotification; import javax.management.MBeanTrustPermission; import javax.management.NotCompliantMBeanException; import javax.management.Notification; @@ -136,6 +138,15 @@ public class Server */ private Map listeners; + /** + * An MBean that emits notifications when an MBean is registered and + * unregistered with this server. + * + */ + private final MBeanServerDelegate delegate; + + static private final AtomicLong sequenceNumber = new AtomicLong(1); + /** * Initialise the delegate name. */ @@ -171,6 +182,7 @@ public class Server { this.defaultDomain = defaultDomain; this.outer = outer; + this.delegate = delegate; try { registerMBean(delegate, DELEGATE_NAME); @@ -1703,6 +1715,7 @@ public class Server beans.put(name, new ServerInfo(obji, obj)); if (register != null) register.postRegister(Boolean.TRUE); + notify(name, MBeanServerNotification.REGISTRATION_NOTIFICATION); return obji; } @@ -2088,10 +2101,18 @@ public class Server } } beans.remove(name); + notify(name, MBeanServerNotification.UNREGISTRATION_NOTIFICATION); if (register != null) register.postDeregister(); } + private void notify(ObjectName name, String type) + { + delegate.sendNotification + (new MBeanServerNotification + (type, DELEGATE_NAME, sequenceNumber.getAndIncrement(), name)); + } + /** * Input stream which deserializes using the given classloader. */ -- cgit v1.2.3