Modifier and Type	Class and Description
private static class	ClientNotifForwarder.LinearExecutor
private class	ClientNotifForwarder.NotifFetcher

Field Summary

Modifier and Type	Field and Description
private boolean	beingReconnected This variable is used to tell whether a connector (RMIConnector or ClientIntermediary) is doing reconnection.
private long	clientSequenceNumber
private Thread	currentFetchThread
private final ClassLoader	defaultClassLoader
private Executor	executor
private final Map<Integer, ClientListenerInfo>	infoList
private static final ClassLogger	logger
private final int	maxNotifications
private Integer	mbeanRemovedNotifID
private static final int	STARTED This state tells that a thread has been started for fetching and forwarding notifications.
private static final int	STARTING This state means that a thread is being created for fetching and forwarding notifications.
private int	state
private static final int	STOPPED This state means that the fetching thread is already stopped.
private static final int	STOPPING This state means that the fetching thread is informed to stop.
private static final int	TERMINATED This state means that this object is terminated and no more thread will be created for fetching notifications.
private static int	threadId
private final long	timeout

Constructor Summary

Access	Constructor and Description
public	ClientNotifForwarder(Map<String, ?> env)
public	ClientNotifForwarder(ClassLoader defaultClassLoader, Map<String, ?> env)

Method Summary

Modifier and Type	Method and Description
protected abstract Integer	addListenerForMBeanRemovedNotif()
public synchronized void	addNotificationListener(Integer listenerID, ObjectName name, NotificationListener listener, NotificationFilter filter, Object handback)
private synchronized void	beforeRemove() Import: should not remove a listener during reconnection, the reconnection needs to change the listener list and that will possibly make removal fail.
protected abstract NotificationResult	fetchNotifs(long clientSequenceNumber, int maxNotifications, long timeout) Called to fetch notifications from a server.
public synchronized Integer	getListenerId(ObjectName name, NotificationListener listener, NotificationFilter filter, Object handback)
public synchronized Integer[]	getListenerIds(ObjectName name, NotificationListener listener)
private synchronized void	init(boolean reconnected)
protected abstract void	lostNotifs(String message, long number) Used to send out a notification about lost notifs
public synchronized void	postReconnection(ClientListenerInfo[] listenerInfos) Called after reconnection is finished.
public synchronized ClientListenerInfo[]	preReconnection()
protected abstract void	removeListenerForMBeanRemovedNotif(Integer id)
public synchronized Integer[]	removeNotificationListener(ObjectName name, NotificationListener listener)
public synchronized Integer	removeNotificationListener(ObjectName name, NotificationListener listener, NotificationFilter filter, Object handback)
public synchronized Integer[]	removeNotificationListener(ObjectName name)
private synchronized void	setState(int newState)
public synchronized void	terminate()

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

Field Detail

beingReconnected	back to summary
private boolean beingReconnected This variable is used to tell whether a connector (RMIConnector or ClientIntermediary) is doing reconnection. This variable will be set to true by the method `preReconnection`, and set to false by `postReconnection`. When beingReconnected == true, no thread will be created for fetching notifications.

clientSequenceNumber	back to summary
private long clientSequenceNumber

currentFetchThread	back to summary
private Thread currentFetchThread

defaultClassLoader	back to summary
private final ClassLoader defaultClassLoader

executor	back to summary
private Executor executor

infoList	back to summary
private final Map<Integer, ClientListenerInfo> infoList

logger	back to summary
private static final ClassLogger logger

maxNotifications	back to summary
private final int maxNotifications

mbeanRemovedNotifID	back to summary
private Integer mbeanRemovedNotifID

STARTED	back to summary
private static final int STARTED This state tells that a thread has been started for fetching and forwarding notifications.

STARTING	back to summary
private static final int STARTING This state means that a thread is being created for fetching and forwarding notifications.

state	back to summary
private int state

STOPPED	back to summary
private static final int STOPPED This state means that the fetching thread is already stopped.

STOPPING	back to summary
private static final int STOPPING This state means that the fetching thread is informed to stop.

TERMINATED	back to summary
private static final int TERMINATED This state means that this object is terminated and no more thread will be created for fetching notifications.

threadId	back to summary
private static int threadId

timeout	back to summary
private final long timeout

Constructor Detail

ClientNotifForwarder	back to summary
public ClientNotifForwarder(Map<String, ?> env)

ClientNotifForwarder	back to summary
public ClientNotifForwarder(ClassLoader defaultClassLoader, Map<String, ?> env) Annotations @SuppressWarnings:removal

Method Detail

addListenerForMBeanRemovedNotif	back to summary
protected abstract Integer addListenerForMBeanRemovedNotif() throws IOException, InstanceNotFoundException

addNotificationListener	back to summary
public synchronized void addNotificationListener(Integer listenerID, ObjectName name, NotificationListener listener, NotificationFilter filter, Object handback) throws IOException, InstanceNotFoundException

beforeRemove	back to summary
private synchronized void beforeRemove() throws IOException Import: should not remove a listener during reconnection, the reconnection needs to change the listener list and that will possibly make removal fail.

fetchNotifs	back to summary
protected abstract NotificationResult fetchNotifs(long clientSequenceNumber, int maxNotifications, long timeout) throws IOException, ClassNotFoundException Called to fetch notifications from a server.

getListenerId	back to summary
public synchronized Integer getListenerId(ObjectName name, NotificationListener listener, NotificationFilter filter, Object handback) throws ListenerNotFoundException, IOException

getListenerIds	back to summary
public synchronized Integer[] getListenerIds(ObjectName name, NotificationListener listener) throws ListenerNotFoundException, IOException

init	back to summary
private synchronized void init(boolean reconnected) throws IOException

lostNotifs	back to summary
protected abstract void lostNotifs(String message, long number) Used to send out a notification about lost notifs

postReconnection	back to summary
public synchronized void postReconnection(ClientListenerInfo[] listenerInfos) throws IOException Called after reconnection is finished. This method is intended to be called only by a client connector: `RMIConnector` and `ClientIntermediary`.

preReconnection	back to summary
public synchronized ClientListenerInfo[] preReconnection() throws IOException

removeListenerForMBeanRemovedNotif	back to summary
protected abstract void removeListenerForMBeanRemovedNotif(Integer id) throws IOException, InstanceNotFoundException, ListenerNotFoundException

removeNotificationListener	back to summary
public synchronized Integer[] removeNotificationListener(ObjectName name, NotificationListener listener) throws ListenerNotFoundException, IOException

removeNotificationListener	back to summary
public synchronized Integer removeNotificationListener(ObjectName name, NotificationListener listener, NotificationFilter filter, Object handback) throws ListenerNotFoundException, IOException

removeNotificationListener	back to summary
public synchronized Integer[] removeNotificationListener(ObjectName name)

setState	back to summary
private synchronized void setState(int newState)

terminate	back to summary
public synchronized void terminate()

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

private Class ClientNotifForwarder.LinearExecutor

Class Inheritance

extends Object
implements Executor

java.lang.Object
com.sun.jmx.remote.internal.ClientNotifForwarder.LinearExecutor

All Implemented Interfaces

java.util.concurrent.Executor

Field Summary

Modifier and Type	Field and Description
private Runnable	command
private Thread	thread

Constructor Summary

Access	Constructor and Description
private	LinearExecutor()

Method Summary

Modifier and Type	Method and Description
public synchronized void	execute(Runnable command) Implements java.util.concurrent.Executor.execute. Executes the given command at some time in the future.

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

Field Detail

command	back to summary
private Runnable command

thread	back to summary
private Thread thread

Constructor Detail

LinearExecutor	back to summary
private LinearExecutor()

Method Detail

execute back to summary

execute	back to summary
public synchronized void execute(Runnable command) Implements java.util.concurrent.Executor.execute. Doc from java.util.concurrent.Executor.execute. Executes the given command at some time in the future. The command may execute in a new thread, in a pooled thread, or in the calling thread, at the discretion of the `Executor` implementation.

public synchronized void execute(Runnable command)

Implements java.util.concurrent.Executor.execute.

Doc from java.util.concurrent.Executor.execute.

Executes the given command at some time in the future. The command may execute in a new thread, in a pooled thread, or in the calling thread, at the discretion of the Executor implementation.

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

private Class ClientNotifForwarder.NotifFetcher

Class Inheritance

extends Object
implements Runnable

java.lang.Object
com.sun.jmx.remote.internal.ClientNotifForwarder.NotifFetcher

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
private volatile boolean	alreadyLogged

Constructor Summary

Access	Constructor and Description
private	NotifFetcher()

Method Summary

Modifier and Type	Method and Description
pack-priv void	dispatchNotification(TargetedNotification tn, Integer myListenerID, Map<Integer, ClientListenerInfo> listeners)
private void	doRun()
private NotificationResult	fetchNotifs()
private NotificationResult	fetchOneNotif()
private boolean	isRejectedExecutionException(Exception e)
private void	logOnce(String msg, SecurityException x)
public void	run() Implements java.lang.Runnable.run. Runs this operation.
private final ClassLoader	setContextClassLoader(final ClassLoader loader)
private boolean	shouldStop()

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

Field Detail

alreadyLogged	back to summary
private volatile boolean alreadyLogged

Constructor Detail

NotifFetcher	back to summary
private NotifFetcher()

Method Detail

dispatchNotification	back to summary
pack-priv void dispatchNotification(TargetedNotification tn, Integer myListenerID, Map<Integer, ClientListenerInfo> listeners)

doRun	back to summary
private void doRun()

fetchNotifs	back to summary
private NotificationResult fetchNotifs()

fetchOneNotif	back to summary
private NotificationResult fetchOneNotif()

isRejectedExecutionException	back to summary
private boolean isRejectedExecutionException(Exception e)

logOnce	back to summary
private void logOnce(String msg, SecurityException x)

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

setContextClassLoader	back to summary
private final ClassLoader setContextClassLoader(final ClassLoader loader)

shouldStop	back to summary
private boolean shouldStop()

public abstract Class ClientNotifForwarder

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class ClientNotifForwarder.LinearExecutor

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class ClientNotifForwarder.NotifFetcher

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail