org.apache.qpid.server.jmx.mbeans

Class VirtualHostManagerMBean

java.lang.Object

javax.management.StandardMBean

org.apache.qpid.server.jmx.DefaultManagedObject

org.apache.qpid.server.jmx.AMQManagedObject

org.apache.qpid.server.jmx.mbeans.VirtualHostManagerMBean

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, NotificationBroadcaster, ManagedBroker, ManagedObject

public class VirtualHostManagerMBean
extends AMQManagedObject
implements ManagedBroker

Field Summary

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

TYPE

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

DOMAIN

Constructor Summary

Constructors

Constructor and Description
VirtualHostManagerMBean(VirtualHostMBean virtualHostMBean)

Method Summary

Modifier and Type	Method and Description
void	createNewExchange(String name, String type, boolean durable) Creates a new Exchange.
void	createNewQueue(String queueName, String owner, boolean durable) Create a new Queue on the Broker server.
void	createNewQueue(String queueName, String owner, boolean durable, Map<String,Object> originalArguments) Create a new Queue in the VirtualHost
void	deleteQueue(String queueName) Unregisters the Queue bindings, removes the subscriptions and unregisters from the managed objects.
protected long	getBytesIn()
protected long	getBytesOut()
protected T	getConfiguredObject()
double	getDataDeliveryRate()
double	getDataReceiptRate()
String[]	getExchangeTypes() Returns an array of the exchange types available for creation.
double	getMessageDeliveryRate()
double	getMessageReceiptRate()
protected long	getMessagesIn()
protected long	getMessagesOut()
String	getObjectInstanceName()
ObjectName	getObjectName() Created the ObjectName as per the JMX Specs
ManagedObject	getParentObject()
double	getPeakDataDeliveryRate()
double	getPeakDataReceiptRate()
double	getPeakMessageDeliveryRate()
double	getPeakMessageReceiptRate()
long	getTotalDataDelivered()
long	getTotalDataReceived()
long	getTotalMessagesDelivered()
long	getTotalMessagesReceived()
protected void	initStats()
boolean	isStatisticsEnabled() Is statistics collection enabled for this connection.
void	resetStatistics()
List<String>	retrieveQueueAttributeNames() Returns a list containing the names of the attributes available for the Queue mbeans.
List<List<Object>>	retrieveQueueAttributeValues(String[] attributes) Returns a List of Object Lists containing the requested attribute values (in the same sequence requested) for each queue in the virtualhost.
void	unregisterExchange(String exchangeName) unregisters all the channels, queuebindings etc and unregisters this exchange from managed objects.
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, 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.ManagedBroker

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

Methods inherited from interface javax.management.NotificationBroadcaster

getNotificationInfo

Constructor Detail

VirtualHostManagerMBean

public VirtualHostManagerMBean(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

getExchangeTypes

public String[] getExchangeTypes()
                          throws IOException

Description copied from interface: ManagedBroker

Returns an array of the exchange types available for creation.

Specified by:

getExchangeTypes in interface ManagedBroker

Throws:

IOException

retrieveQueueAttributeNames

public List<String> retrieveQueueAttributeNames()
                                         throws IOException

Description copied from interface: ManagedBroker

Returns a list containing the names of the attributes available for the Queue mbeans.

Specified by:

retrieveQueueAttributeNames in interface ManagedBroker

Throws:

IOException

retrieveQueueAttributeValues

public List<List<Object>> retrieveQueueAttributeValues(String[] attributes)
                                                throws IOException

Description copied from interface: ManagedBroker

Returns a List of Object Lists containing the requested attribute values (in the same sequence requested) for each queue in the virtualhost. If a particular attribute cant be found or raises an mbean/reflection exception whilst being gathered its value is substituted with the String "-".

Specified by:

retrieveQueueAttributeValues in interface ManagedBroker

Throws:

IOException

createNewExchange

public void createNewExchange(String name,
                              String type,
                              boolean durable)
                       throws IOException,
                              JMException,
                              MBeanException

Description copied from interface: ManagedBroker

Creates a new Exchange.

Specified by:

createNewExchange in interface ManagedBroker

Throws:

IOException

JMException

MBeanException

unregisterExchange

public void unregisterExchange(String exchangeName)
                        throws IOException,
                               JMException,
                               MBeanException

Description copied from interface: ManagedBroker

unregisters all the channels, queuebindings etc and unregisters this exchange from managed objects.

Specified by:

unregisterExchange in interface ManagedBroker

Throws:

IOException

JMException

MBeanException

createNewQueue

public void createNewQueue(String queueName,
                           String owner,
                           boolean durable)
                    throws IOException,
                           JMException,
                           MBeanException

Description copied from interface: ManagedBroker

Create a new Queue on the Broker server.

Specified by:

createNewQueue in interface ManagedBroker

Throws:

IOException

JMException

MBeanException

createNewQueue

public void createNewQueue(String queueName,
                           String owner,
                           boolean durable,
                           Map<String,Object> originalArguments)
                    throws IOException,
                           JMException

Description copied from interface: ManagedBroker

Create a new Queue in the VirtualHost

Specified by:

createNewQueue in interface ManagedBroker

Parameters:

queueName - name of the new queue

owner - owner

durable - true if the queue should be durable

originalArguments - declaration arguments for use when creating the queue, may be null.

Throws:

IOException

JMException

deleteQueue

public void deleteQueue(String queueName)
                 throws IOException,
                        JMException,
                        MBeanException

Description copied from interface: ManagedBroker

Unregisters the Queue bindings, removes the subscriptions and unregisters from the managed objects.

Specified by:

deleteQueue in interface ManagedBroker

Throws:

IOException

JMException

MBeanException

getObjectName

public ObjectName getObjectName()
                         throws MalformedObjectNameException

Description copied from class: DefaultManagedObject

Created the ObjectName as per the JMX Specs

Specified by:

getObjectName in interface ManagedObject

Overrides:

getObjectName in class DefaultManagedObject

Returns:

ObjectName

Throws:

MalformedObjectNameException

isStatisticsEnabled

public boolean isStatisticsEnabled()

Description copied from interface: ManagedBroker

Is statistics collection enabled for this connection.

Specified by:

isStatisticsEnabled in interface ManagedBroker

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()