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
IOException
List<String> retrieveQueueAttributeNames() throws IOException
IOException
List<List<Object>> retrieveQueueAttributeValues(String[] attributes) throws IOException
IOException
void createNewExchange(String name, String type, boolean durable) throws IOException, JMException, MBeanException
name
- type
- durable
- IOException
JMException
MBeanException
void unregisterExchange(String exchange) throws IOException, JMException, MBeanException
exchange
- IOException
JMException
MBeanException
void createNewQueue(String queueName, String owner, boolean durable) throws IOException, JMException, MBeanException
queueName
- durable
- owner
- IOException
JMException
MBeanException
void 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.IOException
JMException
void deleteQueue(String queueName) throws IOException, JMException, MBeanException
queueName
- IOException
JMException
MBeanException
void resetStatistics() throws Exception
Exception
double 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.