com.mongodb

Class JMXConnectionPoolListener

java.lang.Object

com.mongodb.JMXConnectionPoolListener

All Implemented Interfaces:

ConnectionPoolListener, java.util.EventListener

class JMXConnectionPoolListener
extends java.lang.Object
implements ConnectionPoolListener

A connection pool listener that manages a set of JMX MBeans, one for each connection pool.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	JMXConnectionPoolListener.ClusterIdServerAddressPair

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	clusterDescription
private java.util.concurrent.ConcurrentMap<JMXConnectionPoolListener.ClusterIdServerAddressPair,ConnectionPoolStatistics>	map

Constructor Summary

Constructors

Constructor and Description
JMXConnectionPoolListener(java.lang.String clusterDescription)

Method Summary

Modifier and Type	Method and Description
void	connectionAdded(ConnectionEvent event) Invoked when a connection is added to a pool.
void	connectionCheckedIn(ConnectionEvent event) Invoked when a connection is checked in to a pool.
void	connectionCheckedOut(ConnectionEvent event) Invoked when a connection is checked out of a pool.
void	connectionPoolClosed(ConnectionPoolEvent event) Invoked when a connection pool is closed.
void	connectionPoolOpened(ConnectionPoolOpenedEvent event) Invoked when a connection pool is opened.
void	connectionRemoved(ConnectionEvent event) Invoked when a connection is removed from a pool.
ConnectionPoolStatisticsMBean	getMBean(java.lang.String clusterId, ServerAddress serverAddress)
java.lang.String	getMBeanObjectName(java.lang.String clusterId, ServerAddress serverAddress)
private ConnectionPoolStatistics	getStatistics(ConnectionEvent event)
private ConnectionPoolListener	getStatistics(ConnectionPoolEvent event)
private ConnectionPoolStatistics	getStatistics(java.lang.String clusterId, ServerAddress serverAddress)
void	waitQueueEntered(ConnectionPoolWaitQueueEvent event) Invoked when a connection pool's wait queue is entered.
void	waitQueueExited(ConnectionPoolWaitQueueEvent event) Invoked when a connection pools wait queue is exited.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

map

private final java.util.concurrent.ConcurrentMap<JMXConnectionPoolListener.ClusterIdServerAddressPair,ConnectionPoolStatistics> map

clusterDescription

private final java.lang.String clusterDescription

Constructor Detail

JMXConnectionPoolListener

public JMXConnectionPoolListener(java.lang.String clusterDescription)

Method Detail

getMBeanObjectName

public java.lang.String getMBeanObjectName(java.lang.String clusterId,
                                           ServerAddress serverAddress)

getMBean

public ConnectionPoolStatisticsMBean getMBean(java.lang.String clusterId,
                                              ServerAddress serverAddress)

connectionPoolOpened

public void connectionPoolOpened(ConnectionPoolOpenedEvent event)

Description copied from interface: ConnectionPoolListener

Invoked when a connection pool is opened.

Specified by:

connectionPoolOpened in interface ConnectionPoolListener

Parameters:

event - the event

connectionPoolClosed

public void connectionPoolClosed(ConnectionPoolEvent event)

Description copied from interface: ConnectionPoolListener

Invoked when a connection pool is closed.

Specified by:

connectionPoolClosed in interface ConnectionPoolListener

Parameters:

event - the event

connectionCheckedOut

public void connectionCheckedOut(ConnectionEvent event)

Description copied from interface: ConnectionPoolListener

Invoked when a connection is checked out of a pool.

Specified by:

connectionCheckedOut in interface ConnectionPoolListener

Parameters:

event - the event

connectionCheckedIn

public void connectionCheckedIn(ConnectionEvent event)

Description copied from interface: ConnectionPoolListener

Invoked when a connection is checked in to a pool.

Specified by:

connectionCheckedIn in interface ConnectionPoolListener

Parameters:

event - the event

waitQueueEntered

public void waitQueueEntered(ConnectionPoolWaitQueueEvent event)

Description copied from interface: ConnectionPoolListener

Invoked when a connection pool's wait queue is entered.

Specified by:

waitQueueEntered in interface ConnectionPoolListener

Parameters:

event - the event

waitQueueExited

public void waitQueueExited(ConnectionPoolWaitQueueEvent event)

Description copied from interface: ConnectionPoolListener

Invoked when a connection pools wait queue is exited.

Specified by:

waitQueueExited in interface ConnectionPoolListener

Parameters:

event - the event

connectionAdded

public void connectionAdded(ConnectionEvent event)

Description copied from interface: ConnectionPoolListener

Invoked when a connection is added to a pool.

Specified by:

connectionAdded in interface ConnectionPoolListener

Parameters:

event - the event

connectionRemoved

public void connectionRemoved(ConnectionEvent event)

Description copied from interface: ConnectionPoolListener

Invoked when a connection is removed from a pool.

Specified by:

connectionRemoved in interface ConnectionPoolListener

Parameters:

event - the event

getStatistics

private ConnectionPoolStatistics getStatistics(ConnectionEvent event)

getStatistics

private ConnectionPoolListener getStatistics(ConnectionPoolEvent event)

getStatistics

private ConnectionPoolStatistics getStatistics(java.lang.String clusterId,
                                               ServerAddress serverAddress)