public interface ManagedBroker
| 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> arguments)
Create a new Queue in the VirtualHost
|
void |
deleteQueue(String queueName)
Unregisters the Queue bindings, removes the subscriptions and unregisters
from the managed objects.
|
double |
getDataDeliveryRate()
Rate of bytes delivered per second for the virtual host.
|
double |
getDataReceiptRate()
Rate of bytes received per second for the virtual host.
|
String[] |
getExchangeTypes()
Returns an array of the exchange types available for creation.
|
double |
getMessageDeliveryRate()
Rate of messages delivered per second for the virtual host.
|
double |
getMessageReceiptRate()
Rate of messages received per second for the virtual host.
|
double |
getPeakDataDeliveryRate()
Peak rate of bytes delivered per second for the virtual host.
|
double |
getPeakDataReceiptRate()
Peak rate of bytes received per second for the virtual host.
|
double |
getPeakMessageDeliveryRate()
Peak rate of messages delivered per second for the virtual host.
|
double |
getPeakMessageReceiptRate()
Peak rate of messages received per second for the virtual host.
|
long |
getTotalDataDelivered()
Total count of bytes for the virtual host.
|
long |
getTotalDataReceived()
Total count of bytes received for the virtual host.
|
long |
getTotalMessagesDelivered()
Total count of messages delivered for the virtual host.
|
long |
getTotalMessagesReceived()
Total count of messages received for the virtual host.
|
boolean |
isStatisticsEnabled()
Is statistics collection enabled for this connection.
|
void |
resetStatistics()
Resets all message and data statistics for the virtual host.
|
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 exchange)
unregisters all the channels, queuebindings etc and unregisters
this exchange from managed objects.
|
static final String TYPE
String[] getExchangeTypes() throws IOException
IOExceptionList<String> retrieveQueueAttributeNames() throws IOException
IOExceptionList<List<Object>> retrieveQueueAttributeValues(String[] attributes) throws IOException
IOExceptionvoid createNewExchange(String name, String type, boolean durable) throws IOException, JMException, MBeanException
name - type - durable - IOExceptionJMExceptionMBeanExceptionvoid unregisterExchange(String exchange) throws IOException, JMException, MBeanException
exchange - IOExceptionJMExceptionMBeanExceptionvoid createNewQueue(String queueName, String owner, boolean durable) throws IOException, JMException, MBeanException
queueName - durable - owner - IOExceptionJMExceptionMBeanExceptionvoid createNewQueue(String queueName, String owner, boolean durable, Map<String,Object> arguments) throws IOException, JMException
queueName - name of the new queuedurable - true if the queue should be durableowner - ownerarguments - declaration arguments for use when creating the queue, may be null.IOExceptionJMExceptionvoid deleteQueue(String queueName) throws IOException, JMException, MBeanException
queueName - IOExceptionJMExceptionMBeanExceptionvoid resetStatistics()
throws Exception
Exceptiondouble getPeakMessageDeliveryRate()
double getPeakDataDeliveryRate()
double getMessageDeliveryRate()
double getDataDeliveryRate()
long getTotalMessagesDelivered()
long getTotalDataDelivered()
double getPeakMessageReceiptRate()
double getPeakDataReceiptRate()
double getMessageReceiptRate()
double getDataReceiptRate()
long getTotalMessagesReceived()
long getTotalDataReceived()
boolean isStatisticsEnabled()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.