org.apache.qpid.server.protocol
Class AMQProtocolSessionMBean
java.lang.Object
javax.management.StandardMBean
org.apache.qpid.server.management.DefaultManagedObject
org.apache.qpid.server.management.AMQManagedObject
org.apache.qpid.server.protocol.AMQProtocolSessionMBean
- All Implemented Interfaces:
- DynamicMBean, MBeanRegistration, NotificationBroadcaster, org.apache.qpid.management.common.mbeans.ManagedConnection, ManagedObject
public class AMQProtocolSessionMBean
- extends AMQManagedObject
- implements org.apache.qpid.management.common.mbeans.ManagedConnection
This MBean class implements the management interface. In order to make more attributes, operations and notifications
available over JMX simply augment the ManagedConnection interface and add the appropriate implementation here.
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 |
Methods inherited from class org.apache.qpid.server.management.DefaultManagedObject |
getHierarchicalName, getHierarchicalType, getManagedObjectRegistry, getManagementInterface, getObjectName, getObjectNameForSingleInstanceMBean, getType, jmxEncode, 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 |
AMQProtocolSessionMBean
public AMQProtocolSessionMBean(AMQProtocolSession amqProtocolSession)
throws NotCompliantMBeanException,
OpenDataException
- Throws:
NotCompliantMBeanException
OpenDataException
getClientId
public String getClientId()
- Specified by:
getClientId
in interface org.apache.qpid.management.common.mbeans.ManagedConnection
getAuthorizedId
public String getAuthorizedId()
- Specified by:
getAuthorizedId
in interface org.apache.qpid.management.common.mbeans.ManagedConnection
getVersion
public String getVersion()
- Specified by:
getVersion
in interface org.apache.qpid.management.common.mbeans.ManagedConnection
getLastIoTime
public Date getLastIoTime()
- Specified by:
getLastIoTime
in interface org.apache.qpid.management.common.mbeans.ManagedConnection
getRemoteAddress
public String getRemoteAddress()
- Specified by:
getRemoteAddress
in interface org.apache.qpid.management.common.mbeans.ManagedConnection
getParentObject
public ManagedObject getParentObject()
- Specified by:
getParentObject
in interface ManagedObject
- Overrides:
getParentObject
in class DefaultManagedObject
getWrittenBytes
public Long getWrittenBytes()
getReadBytes
public Long getReadBytes()
getMaximumNumberOfChannels
public Long getMaximumNumberOfChannels()
- Specified by:
getMaximumNumberOfChannels
in interface org.apache.qpid.management.common.mbeans.ManagedConnection
setMaximumNumberOfChannels
public void setMaximumNumberOfChannels(Long value)
- Specified by:
setMaximumNumberOfChannels
in interface org.apache.qpid.management.common.mbeans.ManagedConnection
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.
commitTransactions
public void commitTransactions(int channelId)
throws JMException
- commits transactions for a transactional channel
- Specified by:
commitTransactions
in interface org.apache.qpid.management.common.mbeans.ManagedConnection
- Parameters:
channelId
-
- Throws:
JMException
- if channel with given id doesn't exist or if commit fails
rollbackTransactions
public void rollbackTransactions(int channelId)
throws JMException
- rollsback the transactions for a transactional channel
- Specified by:
rollbackTransactions
in interface org.apache.qpid.management.common.mbeans.ManagedConnection
- Parameters:
channelId
-
- Throws:
JMException
- if channel with given id doesn't exist or if rollback fails
channels
public TabularData channels()
throws OpenDataException
- Creates the list of channels in tabular form from the _channelMap.
- Specified by:
channels
in interface org.apache.qpid.management.common.mbeans.ManagedConnection
- Returns:
- list of channels in tabular form.
- Throws:
OpenDataException
closeConnection
public void closeConnection()
throws JMException
- closes the connection. The administrator can use this management operation to close connection to free up
resources.
- Specified by:
closeConnection
in interface org.apache.qpid.management.common.mbeans.ManagedConnection
- Throws:
JMException
getNotificationInfo
public MBeanNotificationInfo[] getNotificationInfo()
- Specified by:
getNotificationInfo
in interface NotificationBroadcaster
- Overrides:
getNotificationInfo
in class AMQManagedObject
notifyClients
public void notifyClients(String notificationMsg)
Licensed to the Apache Software Foundation