org.apache.qpid.server.protocol
Class AMQProtocolSessionMBean

java.lang.Object
  extended by javax.management.StandardMBean
      extended by org.apache.qpid.server.management.DefaultManagedObject
          extended by org.apache.qpid.server.management.AMQManagedObject
              extended by 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.


Field Summary
 
Fields inherited from class org.apache.qpid.server.management.AMQManagedObject
_broadcaster, _logActor, _mbeanInfo, _notificationSequenceNumber
 
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.management.ManagedObject
DOMAIN
 
Constructor Summary
AMQProtocolSessionMBean(AMQProtocolSession amqProtocolSession)
           
 
Method Summary
 TabularData channels()
          Creates the list of channels in tabular form from the _channelMap.
 void closeConnection()
          closes the connection.
 void commitTransactions(int channelId)
          commits transactions for a transactional channel
 String getAuthorizedId()
           
 String getClientId()
           
 Date getLastIoTime()
           
 Long getMaximumNumberOfChannels()
           
 MBeanNotificationInfo[] getNotificationInfo()
           
 String getObjectInstanceName()
           
 ManagedObject getParentObject()
           
 Long getReadBytes()
           
 String getRemoteAddress()
           
 String getVersion()
           
 Long getWrittenBytes()
           
 void notifyClients(String notificationMsg)
           
 void rollbackTransactions(int channelId)
          rollsback the transactions for a transactional channel
 void setMaximumNumberOfChannels(Long value)
           
 
Methods inherited from class org.apache.qpid.server.management.AMQManagedObject
addNotificationListener, getMBeanInfo, removeNotificationListener
 
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

AMQProtocolSessionMBean

public AMQProtocolSessionMBean(AMQProtocolSession amqProtocolSession)
                        throws NotCompliantMBeanException,
                               OpenDataException
Throws:
NotCompliantMBeanException
OpenDataException
Method Detail

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