summaryrefslogtreecommitdiff
path: root/qpid/java/broker/src/main/java/org/apache/qpid/server/management/AMQManagedObject.java
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/server/management/AMQManagedObject.java')
-rw-r--r--qpid/java/broker/src/main/java/org/apache/qpid/server/management/AMQManagedObject.java49
1 files changed, 36 insertions, 13 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/management/AMQManagedObject.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/management/AMQManagedObject.java
index 6c9d6e39de..5c57c01f6e 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/management/AMQManagedObject.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/management/AMQManagedObject.java
@@ -20,13 +20,11 @@
*/
package org.apache.qpid.server.management;
-import org.apache.qpid.server.logging.actors.ManagementActor;
-import org.apache.qpid.server.logging.actors.CurrentActor;
import org.apache.qpid.server.logging.LogActor;
+import org.apache.qpid.server.logging.actors.CurrentActor;
+import org.apache.qpid.server.logging.actors.ManagementActor;
import javax.management.ListenerNotFoundException;
-import javax.management.MBeanInfo;
-import javax.management.MBeanNotificationInfo;
import javax.management.NotCompliantMBeanException;
import javax.management.NotificationBroadcaster;
import javax.management.NotificationBroadcasterSupport;
@@ -42,17 +40,11 @@ import javax.management.NotificationListener;
public abstract class AMQManagedObject extends DefaultManagedObject
implements NotificationBroadcaster
{
- /**
- * broadcaster support class
- */
- protected NotificationBroadcasterSupport _broadcaster = new NotificationBroadcasterSupport();
+ private NotificationBroadcasterSupport _broadcaster = new NotificationBroadcasterSupport();
- /**
- * sequence number for notifications
- */
- protected long _notificationSequenceNumber = 0;
+ private long _notificationSequenceNumber = 0;
- protected LogActor _logActor;
+ private LogActor _logActor;
protected AMQManagedObject(Class<?> managementInterface, String typeName)
throws NotCompliantMBeanException
@@ -79,4 +71,35 @@ public abstract class AMQManagedObject extends DefaultManagedObject
}
+ /**
+ * broadcaster support class
+ */
+ protected NotificationBroadcasterSupport getBroadcaster()
+ {
+ return _broadcaster;
+ }
+
+ /**
+ * sequence number for notifications
+ */
+ protected long getNotificationSequenceNumber()
+ {
+ return _notificationSequenceNumber;
+ }
+
+ protected void setNotificationSequenceNumber(long notificationSequenceNumber)
+ {
+ _notificationSequenceNumber = notificationSequenceNumber;
+ }
+
+ protected long incrementAndGetSequenceNumber()
+ {
+ return ++_notificationSequenceNumber;
+ }
+
+ protected LogActor getLogActor()
+ {
+ return _logActor;
+ }
+
}