org.apache.qpid.server.jmx.mbeans

Class ConnectionMBean

java.lang.Object

javax.management.StandardMBean

org.apache.qpid.server.jmx.DefaultManagedObject

org.apache.qpid.server.jmx.AMQManagedObject

org.apache.qpid.server.jmx.mbeans.ConnectionMBean

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, NotificationBroadcaster, ManagedConnection, ManagedObject

public class ConnectionMBean
extends AMQManagedObject
implements ManagedConnection

Field Summary

Fields inherited from interface org.apache.qpid.management.common.mbeans.ManagedConnection

CHAN_ID, COMPOSITE_ITEM_NAMES_DESC, DEFAULT_QUEUE, FLOW_BLOCKED, TABULAR_UNIQUE_INDEX, TRANSACTIONAL, TYPE, UNACKED_COUNT

Fields inherited from interface org.apache.qpid.server.jmx.ManagedObject

DOMAIN

Constructor Summary

Constructors

Constructor and Description
ConnectionMBean(Connection conn, VirtualHostMBean virtualHostMBean)

Method Summary

Modifier and Type	Method and Description
TabularData	channels() channel details of all the channels opened for this connection.
void	closeConnection() Closes all the related channels and unregisters this connection from managed objects.
void	commitTransactions(int channelId) Commits the transactions if the channel is transactional.
String	getAuthorizedId()
protected long	getBytesIn()
protected long	getBytesOut()
String	getClientId()
protected T	getConfiguredObject()
double	getDataDeliveryRate()
double	getDataReceiptRate()
Date	getLastIoTime() Tells the last time, the IO operation was done.
Long	getMaximumNumberOfChannels() Threshold high value for no of channels.
double	getMessageDeliveryRate()
double	getMessageReceiptRate()
protected long	getMessagesIn()
protected long	getMessagesOut()
String	getObjectInstanceName()
ManagedObject	getParentObject()
double	getPeakDataDeliveryRate()
double	getPeakDataReceiptRate()
double	getPeakMessageDeliveryRate()
double	getPeakMessageReceiptRate()
String	getRemoteAddress() Tells the remote address of this connection.
long	getTotalDataDelivered()
long	getTotalDataReceived()
long	getTotalMessagesDelivered()
long	getTotalMessagesReceived()
String	getVersion()
protected void	initStats()
boolean	isStatisticsEnabled() Is statistics collection enabled for this connection.
void	resetStatistics()
void	rollbackTransactions(int channelId) Rollsback the transactions if the channel is transactional.
void	setStatisticsEnabled(boolean enabled) Sets statistics collection enabled/disabled for this connection.
protected void	updateStats()

Methods inherited from class org.apache.qpid.server.jmx.AMQManagedObject

addNotificationListener, getBroadcaster, incrementAndGetSequenceNumber, removeNotificationListener

Methods inherited from class org.apache.qpid.server.jmx.DefaultManagedObject

getHierarchicalName, getHierarchicalType, getManagementInterface, getMBeanInfo, getNotificationInfo, getObjectName, getObjectNameForSingleInstanceMBean, getRegistry, getType, register, toString, unregister

Methods inherited from class javax.management.StandardMBean

cacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementation

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.qpid.management.common.mbeans.ManagedConnection

getDataDeliveryRate, getDataReceiptRate, getMessageDeliveryRate, getMessageReceiptRate, getPeakDataDeliveryRate, getPeakDataReceiptRate, getPeakMessageDeliveryRate, getPeakMessageReceiptRate, getTotalDataDelivered, getTotalDataReceived, getTotalMessagesDelivered, getTotalMessagesReceived, resetStatistics

Methods inherited from interface javax.management.NotificationBroadcaster

getNotificationInfo

Constructor Detail

ConnectionMBean

public ConnectionMBean(Connection conn,
                       VirtualHostMBean virtualHostMBean)
                throws JMException

Throws:

JMException

Method Detail

getBytesOut

protected long getBytesOut()

getBytesIn

protected long getBytesIn()

getMessagesOut

protected long getMessagesOut()

getMessagesIn

protected long getMessagesIn()

getObjectInstanceName

public String getObjectInstanceName()

Specified by:

getObjectInstanceName in interface ManagedObject

Returns:

the name that uniquely identifies this object instance. It must be unique only among objects of this type at this level in the hierarchy so the uniqueness should not be too difficult to ensure.

getParentObject

public ManagedObject getParentObject()

Specified by:

getParentObject in interface ManagedObject

Specified by:

getParentObject in class DefaultManagedObject

getClientId

public String getClientId()

Specified by:

getClientId in interface ManagedConnection

getAuthorizedId

public String getAuthorizedId()

Specified by:

getAuthorizedId in interface ManagedConnection

getVersion

public String getVersion()

Specified by:

getVersion in interface ManagedConnection

getRemoteAddress

public String getRemoteAddress()

Description copied from interface: ManagedConnection

Tells the remote address of this connection.

Specified by:

getRemoteAddress in interface ManagedConnection

Returns:

remote address

getLastIoTime

public Date getLastIoTime()

Description copied from interface: ManagedConnection

Tells the last time, the IO operation was done.

Specified by:

getLastIoTime in interface ManagedConnection

Returns:

last IO time.

getMaximumNumberOfChannels

public Long getMaximumNumberOfChannels()

Description copied from interface: ManagedConnection

Threshold high value for no of channels. This is useful in setting notifications or taking required action is there are more channels being created.

Specified by:

getMaximumNumberOfChannels in interface ManagedConnection

Returns:

threshold limit for no of channels

channels

public TabularData channels()
                     throws IOException,
                            JMException

Description copied from interface: ManagedConnection

channel details of all the channels opened for this connection.

Specified by:

channels in interface ManagedConnection

Returns:

general channel details

Throws:

IOException

JMException

commitTransactions

public void commitTransactions(int channelId)
                        throws JMException

Description copied from interface: ManagedConnection

Commits the transactions if the channel is transactional.

Specified by:

commitTransactions in interface ManagedConnection

Throws:

JMException

rollbackTransactions

public void rollbackTransactions(int channelId)
                          throws JMException

Description copied from interface: ManagedConnection

Rollsback the transactions if the channel is transactional.

Specified by:

rollbackTransactions in interface ManagedConnection

Throws:

JMException

closeConnection

public void closeConnection()
                     throws Exception

Description copied from interface: ManagedConnection

Closes all the related channels and unregisters this connection from managed objects.

Specified by:

closeConnection in interface ManagedConnection

Throws:

Exception

isStatisticsEnabled

public boolean isStatisticsEnabled()

Description copied from interface: ManagedConnection

Is statistics collection enabled for this connection.

Specified by:

isStatisticsEnabled in interface ManagedConnection

setStatisticsEnabled

public void setStatisticsEnabled(boolean enabled)

Description copied from interface: ManagedConnection

Sets statistics collection enabled/disabled for this connection.

Specified by:

setStatisticsEnabled in interface ManagedConnection

initStats

protected void initStats()

updateStats

protected void updateStats()

resetStatistics

public void resetStatistics()
                     throws Exception

Throws:

Exception

getPeakMessageDeliveryRate

public double getPeakMessageDeliveryRate()

getPeakDataDeliveryRate

public double getPeakDataDeliveryRate()

getMessageDeliveryRate

public double getMessageDeliveryRate()

getDataDeliveryRate

public double getDataDeliveryRate()

getTotalMessagesDelivered

public long getTotalMessagesDelivered()

getTotalDataDelivered

public long getTotalDataDelivered()

getConfiguredObject

protected final T getConfiguredObject()

getPeakMessageReceiptRate

public double getPeakMessageReceiptRate()

getPeakDataReceiptRate

public double getPeakDataReceiptRate()

getMessageReceiptRate

public double getMessageReceiptRate()

getDataReceiptRate

public double getDataReceiptRate()

getTotalMessagesReceived

public long getTotalMessagesReceived()

getTotalDataReceived

public long getTotalDataReceived()