Modifier and Type	Class and Description
private static class	ArrayNotificationBuffer.BroadcasterQuery
private class	ArrayNotificationBuffer.BufferListener
private static class	ArrayNotificationBuffer.NamedNotification
private class	ArrayNotificationBuffer.ShareBuffer

Modifier and Type	Field and Description
pack-priv static final String	broadcasterClass
private static final QueryExp	broadcasterQuery
private final NotificationListener	bufferListener
private Set<ObjectName>	createdDuringQuery
private static final NotificationFilter	creationFilter
private final NotificationListener	creationListener
private boolean	disposed
private long	earliestSequenceNumber
private static final Object	globalLock
private static final ClassLogger	logger
private final MBeanServer	mBeanServer
private static final HashMap<MBeanServer, ArrayNotificationBuffer>	mbsToBuffer
private long	nextSequenceNumber
private final ArrayQueue<ArrayNotificationBuffer.NamedNotification>	queue
private int	queueSize
private final Collection<ArrayNotificationBuffer.ShareBuffer>	sharers

Access	Constructor and Description
private	ArrayNotificationBuffer(MBeanServer mbs, int queueSize)

Method Summary

Modifier and Type	Method and Description
private void	addBufferListener(ObjectName name)
pack-priv synchronized void	addNotification(ArrayNotificationBuffer.NamedNotification notif)
private void	addNotificationListener(final ObjectName name, final NotificationListener listener, final NotificationFilter filter, final Object handback)
pack-priv void	addSharer(ArrayNotificationBuffer.ShareBuffer sharer)
private void	checkNoLocks()
private void	createdNotification(MBeanServerNotification n)
private void	createListeners()
private void	destroyListeners()
public void	dispose() Implements com.sun.jmx.remote.internal.NotificationBuffer.dispose. Discard this buffer.
private void	dropNotification()
pack-priv synchronized long	earliestSequenceNumber()
public NotificationResult	fetchNotifications(NotificationBufferFilter an object that will add notifications to a `List<TargetedNotification>` if they match the current listeners with their filters. filter, long the first sequence number to consider. startSequenceNumber, long the maximum time to wait. May be 0 to indicate not to wait if there are no notifications. timeout, int the maximum number of notifications to return. May be 0 to indicate a wait for eligible notifications that will return a usable `nextSequenceNumber`. The `TargetedNotification` array in the returned `NotificationResult` may contain more than this number of elements but will not contain more than this number of different notifications. maxNotifications) Implements com.sun.jmx.remote.internal.NotificationBuffer.fetchNotifications. Fetch notifications that match the given listeners.
public static NotificationBuffer	getNotificationBuffer(MBeanServer mbs, Map<String, ?> env)
private synchronized boolean	isDisposed()
private static boolean	isInstanceOf(final MBeanServer mbs, final ObjectName name, final String className)
pack-priv synchronized long	nextSequenceNumber()
pack-priv synchronized ArrayNotificationBuffer.NamedNotification	notificationAt(long seqNo)
private Set<ObjectName>	queryNames(final ObjectName name, final QueryExp query)
private void	removeBufferListener(ObjectName name)
pack-priv static void	removeNotificationBuffer(MBeanServer mbs)
private void	removeNotificationListener(final ObjectName name, final NotificationListener listener)
private void	removeSharer(ArrayNotificationBuffer.ShareBuffer sharer)
private synchronized void	resize(int newSize)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

broadcasterClass	back to summary
pack-priv static final String broadcasterClass

broadcasterQuery	back to summary
private static final QueryExp broadcasterQuery

bufferListener	back to summary
private final NotificationListener bufferListener

createdDuringQuery	back to summary
private Set<ObjectName> createdDuringQuery

creationFilter	back to summary
private static final NotificationFilter creationFilter

creationListener	back to summary
private final NotificationListener creationListener

disposed	back to summary
private boolean disposed

earliestSequenceNumber	back to summary
private long earliestSequenceNumber

globalLock	back to summary
private static final Object globalLock

logger	back to summary
private static final ClassLogger logger

mBeanServer	back to summary
private final MBeanServer mBeanServer

mbsToBuffer	back to summary
private static final HashMap<MBeanServer, ArrayNotificationBuffer> mbsToBuffer

nextSequenceNumber	back to summary
private long nextSequenceNumber

queue	back to summary
private final ArrayQueue<ArrayNotificationBuffer.NamedNotification> queue

queueSize	back to summary
private int queueSize

sharers	back to summary
private final Collection<ArrayNotificationBuffer.ShareBuffer> sharers

Constructor Detail

ArrayNotificationBuffer	back to summary
private ArrayNotificationBuffer(MBeanServer mbs, int queueSize)

Method Detail

addBufferListener	back to summary
private void addBufferListener(ObjectName name)

addNotification	back to summary
pack-priv synchronized void addNotification(ArrayNotificationBuffer.NamedNotification notif)

addNotificationListener	back to summary
private void addNotificationListener(final ObjectName name, final NotificationListener listener, final NotificationFilter filter, final Object handback) throws Exception

addSharer	back to summary
pack-priv void addSharer(ArrayNotificationBuffer.ShareBuffer sharer)

checkNoLocks	back to summary
private void checkNoLocks()

createdNotification	back to summary
private void createdNotification(MBeanServerNotification n)

createListeners	back to summary
private void createListeners()

destroyListeners	back to summary
private void destroyListeners()

dispose	back to summary
public void dispose() Implements com.sun.jmx.remote.internal.NotificationBuffer.dispose. Doc from com.sun.jmx.remote.internal.NotificationBuffer.dispose. Discard this buffer.

dispose

back to summary

public void dispose()

Implements com.sun.jmx.remote.internal.NotificationBuffer.dispose.

Doc from com.sun.jmx.remote.internal.NotificationBuffer.dispose.

Discard this buffer.

dropNotification	back to summary
private void dropNotification()

earliestSequenceNumber	back to summary
pack-priv synchronized long earliestSequenceNumber()

fetchNotifications back to summary

fetchNotifications	back to summary
public NotificationResult fetchNotifications(NotificationBufferFilter filter, long startSequenceNumber, long timeout, int maxNotifications) throws InterruptedException Implements com.sun.jmx.remote.internal.NotificationBuffer.fetchNotifications. Fetch notifications that match the given listeners. The operation only considers notifications with a sequence number at least `startSequenceNumber`. It will take no longer than `timeout`, and will return no more than `maxNotifications` different notifications. If there are no notifications matching the criteria, the operation will block until one arrives, subject to the timeout. Parameters filter:NotificationBufferFilter an object that will add notifications to a `List<TargetedNotification>` if they match the current listeners with their filters. startSequenceNumber:long the first sequence number to consider. timeout:long the maximum time to wait. May be 0 to indicate not to wait if there are no notifications. maxNotifications:int the maximum number of notifications to return. May be 0 to indicate a wait for eligible notifications that will return a usable `nextSequenceNumber`. The `TargetedNotification` array in the returned `NotificationResult` may contain more than this number of elements but will not contain more than this number of different notifications.

public NotificationResult fetchNotifications(NotificationBufferFilter filter, long startSequenceNumber, long timeout, int maxNotifications) throws InterruptedException

Implements com.sun.jmx.remote.internal.NotificationBuffer.fetchNotifications.

Fetch notifications that match the given listeners.

The operation only considers notifications with a sequence number at least startSequenceNumber. It will take no longer than timeout, and will return no more than maxNotifications different notifications.

If there are no notifications matching the criteria, the operation will block until one arrives, subject to the timeout.

Parameters

filter:NotificationBufferFilter: an object that will add notifications to a List<TargetedNotification> if they match the current listeners with their filters.
startSequenceNumber:long: the first sequence number to consider.
timeout:long: the maximum time to wait. May be 0 to indicate not to wait if there are no notifications.
maxNotifications:int: the maximum number of notifications to return. May be 0 to indicate a wait for eligible notifications that will return a usable nextSequenceNumber. The TargetedNotification array in the returned NotificationResult may contain more than this number of elements but will not contain more than this number of different notifications.

getNotificationBuffer	back to summary
public static NotificationBuffer getNotificationBuffer(MBeanServer mbs, Map<String, ?> env)

isDisposed	back to summary
private synchronized boolean isDisposed()

isInstanceOf	back to summary
private static boolean isInstanceOf(final MBeanServer mbs, final ObjectName name, final String className)

nextSequenceNumber	back to summary
pack-priv synchronized long nextSequenceNumber()

notificationAt	back to summary
pack-priv synchronized ArrayNotificationBuffer.NamedNotification notificationAt(long seqNo)

queryNames	back to summary
private Set<ObjectName> queryNames(final ObjectName name, final QueryExp query)

removeBufferListener	back to summary
private void removeBufferListener(ObjectName name)

removeNotificationBuffer	back to summary
pack-priv static void removeNotificationBuffer(MBeanServer mbs)

removeNotificationListener	back to summary
private void removeNotificationListener(final ObjectName name, final NotificationListener listener) throws Exception

removeSharer	back to summary
private void removeSharer(ArrayNotificationBuffer.ShareBuffer sharer)

resize	back to summary
private synchronized void resize(int newSize)

com.sun.jmx.remote.internal back to summary

private Class ArrayNotificationBuffer.BroadcasterQuery

Class Inheritance

extends QueryEval
implements QueryExp

java.lang.Object
javax.management.QueryEval
com.sun.jmx.remote.internal.ArrayNotificationBuffer.BroadcasterQuery

All Implemented Interfaces

javax.management.QueryExp, java.io.Serializable

Field Summary

Modifier and Type	Field and Description
private static final long	serialVersionUID Hides javax.management.QueryEval.serialVersionUID.

Constructor Summary

Access	Constructor and Description
private	BroadcasterQuery()

Method Summary

Modifier and Type	Method and Description
public boolean	apply(final ObjectName name) Implements javax.management.QueryExp.apply. Applies the QueryExp on an MBean.

Inherited from javax.management.QueryEval:: getMBeanServer setMBeanServer

Field Detail

serialVersionUID	back to summary
private static final long serialVersionUID Hides javax.management.QueryEval.serialVersionUID.

Constructor Detail

BroadcasterQuery	back to summary
private BroadcasterQuery()

Method Detail

apply	back to summary
public boolean apply(final ObjectName name) Implements javax.management.QueryExp.apply. Doc from javax.management.QueryExp.apply. Applies the QueryExp on an MBean.

apply

back to summary

public boolean apply(final ObjectName name)

Implements javax.management.QueryExp.apply.

Doc from javax.management.QueryExp.apply.

Applies the QueryExp on an MBean.

com.sun.jmx.remote.internal back to summary

private Class ArrayNotificationBuffer.BufferListener

Class Inheritance

extends Object
implements NotificationListener

java.lang.Object
com.sun.jmx.remote.internal.ArrayNotificationBuffer.BufferListener

All Implemented Interfaces

javax.management.NotificationListener, java.util.EventListener

Constructor Summary

Access	Constructor and Description
private	BufferListener()

Method Summary

Modifier and Type	Method and Description
public void	handleNotification(Notification notif, Object handback) Implements javax.management.NotificationListener.handleNotification. Invoked when a JMX notification occurs.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

BufferListener	back to summary
private BufferListener()

Method Detail

handleNotification

back to summary

public void handleNotification(Notification notif, Object handback)

Implements javax.management.NotificationListener.handleNotification.

Doc from javax.management.NotificationListener.handleNotification.

Invoked when a JMX notification occurs. The implementation of this method should return as soon as possible, to avoid blocking its notification broadcaster.

com.sun.jmx.remote.internal back to summary

private Class ArrayNotificationBuffer.NamedNotification

Class Inheritance

extends Object

java.lang.Object
com.sun.jmx.remote.internal.ArrayNotificationBuffer.NamedNotification

Field Summary

Modifier and Type	Field and Description
private final Notification	notification
private final ObjectName	sender

Constructor Summary

Access	Constructor and Description
pack-priv	NamedNotification(ObjectName sender, Notification notif)

Method Summary

Modifier and Type	Method and Description
pack-priv Notification	getNotification()
pack-priv ObjectName	getObjectName()
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

notification	back to summary
private final Notification notification

sender	back to summary
private final ObjectName sender

Constructor Detail

NamedNotification	back to summary
pack-priv NamedNotification(ObjectName sender, Notification notif)

Method Detail

getNotification	back to summary
pack-priv Notification getNotification()

getObjectName	back to summary
pack-priv ObjectName getObjectName()

toString back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

com.sun.jmx.remote.internal back to summary

private Class ArrayNotificationBuffer.ShareBuffer

Class Inheritance

extends Object
implements NotificationBuffer

java.lang.Object
com.sun.jmx.remote.internal.ArrayNotificationBuffer.ShareBuffer

All Implemented Interfaces

com.sun.jmx.remote.internal.NotificationBuffer

Field Summary

Modifier and Type	Field and Description
private final int	size

Constructor Summary

Access	Constructor and Description
pack-priv	ShareBuffer(int size)

Method Summary

Modifier and Type	Method and Description
public void	dispose() Implements com.sun.jmx.remote.internal.NotificationBuffer.dispose. Discard this buffer.
public NotificationResult	fetchNotifications(NotificationBufferFilter filter, long startSequenceNumber, long timeout, int maxNotifications) Implements com.sun.jmx.remote.internal.NotificationBuffer.fetchNotifications. Fetch notifications that match the given listeners.
pack-priv int	getSize()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

size	back to summary
private final int size

Constructor Detail

ShareBuffer	back to summary
pack-priv ShareBuffer(int size)

Method Detail

dispose

back to summary

public void dispose()

Implements com.sun.jmx.remote.internal.NotificationBuffer.dispose.

Doc from com.sun.jmx.remote.internal.NotificationBuffer.dispose.

Discard this buffer.

fetchNotifications back to summary

public NotificationResult fetchNotifications(NotificationBufferFilter filter, long startSequenceNumber, long timeout, int maxNotifications) throws InterruptedException

Implements com.sun.jmx.remote.internal.NotificationBuffer.fetchNotifications.

Doc from com.sun.jmx.remote.internal.NotificationBuffer.fetchNotifications.

Fetch notifications that match the given listeners.

If there are no notifications matching the criteria, the operation will block until one arrives, subject to the timeout.

getSize	back to summary
pack-priv int getSize()

public Class ArrayNotificationBuffer

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class ArrayNotificationBuffer.BroadcasterQuery

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class ArrayNotificationBuffer.BufferListener

Constructor Summary

Method Summary

Constructor Detail

Method Detail

private Class ArrayNotificationBuffer.NamedNotification

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class ArrayNotificationBuffer.ShareBuffer

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail