public class VirtualHostManagerMBean extends AMQManagedObject implements ManagedBroker
TYPE
DOMAIN
Constructor and Description |
---|
VirtualHostManagerMBean(VirtualHostMBean virtualHostMBean) |
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() |
addNotificationListener, getBroadcaster, incrementAndGetSequenceNumber, removeNotificationListener
getHierarchicalName, getHierarchicalType, getManagementInterface, getMBeanInfo, getNotificationInfo, getObjectNameForSingleInstanceMBean, getRegistry, getType, register, toString, unregister
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getDataDeliveryRate, getDataReceiptRate, getMessageDeliveryRate, getMessageReceiptRate, getPeakDataDeliveryRate, getPeakDataReceiptRate, getPeakMessageDeliveryRate, getPeakMessageReceiptRate, getTotalDataDelivered, getTotalDataReceived, getTotalMessagesDelivered, getTotalMessagesReceived, resetStatistics
getNotificationInfo
public VirtualHostManagerMBean(VirtualHostMBean virtualHostMBean) throws JMException
JMException
protected long getBytesOut()
protected long getBytesIn()
protected long getMessagesOut()
protected long getMessagesIn()
public String getObjectInstanceName()
getObjectInstanceName
in interface ManagedObject
public ManagedObject getParentObject()
getParentObject
in interface ManagedObject
getParentObject
in class DefaultManagedObject
public String[] getExchangeTypes() throws IOException
ManagedBroker
getExchangeTypes
in interface ManagedBroker
IOException
public List<String> retrieveQueueAttributeNames() throws IOException
ManagedBroker
retrieveQueueAttributeNames
in interface ManagedBroker
IOException
public List<List<Object>> retrieveQueueAttributeValues(String[] attributes) throws IOException
ManagedBroker
retrieveQueueAttributeValues
in interface ManagedBroker
IOException
public void createNewExchange(String name, String type, boolean durable) throws IOException, JMException, MBeanException
ManagedBroker
createNewExchange
in interface ManagedBroker
IOException
JMException
MBeanException
public void unregisterExchange(String exchangeName) throws IOException, JMException, MBeanException
ManagedBroker
unregisterExchange
in interface ManagedBroker
IOException
JMException
MBeanException
public void createNewQueue(String queueName, String owner, boolean durable) throws IOException, JMException, MBeanException
ManagedBroker
createNewQueue
in interface ManagedBroker
IOException
JMException
MBeanException
public void createNewQueue(String queueName, String owner, boolean durable, Map<String,Object> originalArguments) throws IOException, JMException
ManagedBroker
createNewQueue
in interface ManagedBroker
queueName
- name of the new queueowner
- ownerdurable
- true if the queue should be durableoriginalArguments
- declaration arguments for use when creating the queue, may be null.IOException
JMException
public void deleteQueue(String queueName) throws IOException, JMException, MBeanException
ManagedBroker
deleteQueue
in interface ManagedBroker
IOException
JMException
MBeanException
public ObjectName getObjectName() throws MalformedObjectNameException
DefaultManagedObject
getObjectName
in interface ManagedObject
getObjectName
in class DefaultManagedObject
MalformedObjectNameException
public boolean isStatisticsEnabled()
ManagedBroker
isStatisticsEnabled
in interface ManagedBroker
protected void initStats()
protected void updateStats()
public double getPeakMessageDeliveryRate()
public double getPeakDataDeliveryRate()
public double getMessageDeliveryRate()
public double getDataDeliveryRate()
public long getTotalMessagesDelivered()
public long getTotalDataDelivered()
protected final T getConfiguredObject()
public double getPeakMessageReceiptRate()
public double getPeakDataReceiptRate()
public double getMessageReceiptRate()
public double getDataReceiptRate()
public long getTotalMessagesReceived()
public long getTotalDataReceived()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.