public class BrokerView extends Object implements BrokerViewMBean
Constructor and Description |
---|
BrokerView(BrokerService brokerService,
ManagedRegionBroker managedBroker) |
public BrokerView(BrokerService brokerService, ManagedRegionBroker managedBroker) throws Exception
Exception
public ManagedRegionBroker getBroker()
public void setBroker(ManagedRegionBroker broker)
public String getBrokerId()
getBrokerId
in interface BrokerViewMBean
public String getBrokerName()
getBrokerName
in interface BrokerViewMBean
public String getBrokerVersion()
getBrokerVersion
in interface BrokerViewMBean
public void gc() throws Exception
BrokerViewMBean
gc
in interface BrokerViewMBean
Exception
public void start() throws Exception
public void stop() throws Exception
BrokerViewMBean
stop
in interface BrokerViewMBean
stop
in interface Service
Exception
public void stopGracefully(String connectorName, String queueName, long timeout, long pollInterval) throws Exception
stopGracefully
in interface BrokerViewMBean
Exception
public long getTotalEnqueueCount()
getTotalEnqueueCount
in interface BrokerViewMBean
public long getTotalDequeueCount()
getTotalDequeueCount
in interface BrokerViewMBean
public long getTotalConsumerCount()
getTotalConsumerCount
in interface BrokerViewMBean
public long getTotalProducerCount()
getTotalProducerCount
in interface BrokerViewMBean
public long getTotalMessageCount()
getTotalMessageCount
in interface BrokerViewMBean
public long getTotalMessagesCached()
public int getMemoryPercentUsage()
getMemoryPercentUsage
in interface BrokerViewMBean
public long getMemoryLimit()
getMemoryLimit
in interface BrokerViewMBean
public void setMemoryLimit(long limit)
setMemoryLimit
in interface BrokerViewMBean
public long getStoreLimit()
getStoreLimit
in interface BrokerViewMBean
public int getStorePercentUsage()
getStorePercentUsage
in interface BrokerViewMBean
public long getTempLimit()
getTempLimit
in interface BrokerViewMBean
public int getTempPercentUsage()
getTempPercentUsage
in interface BrokerViewMBean
public void setStoreLimit(long limit)
setStoreLimit
in interface BrokerViewMBean
public void setTempLimit(long limit)
setTempLimit
in interface BrokerViewMBean
public void resetStatistics()
resetStatistics
in interface BrokerViewMBean
public void enableStatistics()
enableStatistics
in interface BrokerViewMBean
public void disableStatistics()
disableStatistics
in interface BrokerViewMBean
public boolean isStatisticsEnabled()
isStatisticsEnabled
in interface BrokerViewMBean
public boolean isPersistent()
isPersistent
in interface BrokerViewMBean
public boolean isSlave()
isSlave
in interface BrokerViewMBean
public void terminateJVM(int exitCode)
BrokerViewMBean
terminateJVM
in interface BrokerViewMBean
exitCode
- the exit code that will be reported by the JVM process
when it exits.public ObjectName[] getTopics()
getTopics
in interface BrokerViewMBean
public ObjectName[] getQueues()
getQueues
in interface BrokerViewMBean
public ObjectName[] getTemporaryTopics()
getTemporaryTopics
in interface BrokerViewMBean
public ObjectName[] getTemporaryQueues()
getTemporaryQueues
in interface BrokerViewMBean
public ObjectName[] getTopicSubscribers()
getTopicSubscribers
in interface BrokerViewMBean
public ObjectName[] getDurableTopicSubscribers()
getDurableTopicSubscribers
in interface BrokerViewMBean
public ObjectName[] getQueueSubscribers()
getQueueSubscribers
in interface BrokerViewMBean
public ObjectName[] getTemporaryTopicSubscribers()
getTemporaryTopicSubscribers
in interface BrokerViewMBean
public ObjectName[] getTemporaryQueueSubscribers()
getTemporaryQueueSubscribers
in interface BrokerViewMBean
public ObjectName[] getInactiveDurableTopicSubscribers()
getInactiveDurableTopicSubscribers
in interface BrokerViewMBean
public ObjectName[] getTopicProducers()
getTopicProducers
in interface BrokerViewMBean
public ObjectName[] getQueueProducers()
getQueueProducers
in interface BrokerViewMBean
public ObjectName[] getTemporaryTopicProducers()
getTemporaryTopicProducers
in interface BrokerViewMBean
public ObjectName[] getTemporaryQueueProducers()
getTemporaryQueueProducers
in interface BrokerViewMBean
public ObjectName[] getDynamicDestinationProducers()
getDynamicDestinationProducers
in interface BrokerViewMBean
public String addConnector(String discoveryAddress) throws Exception
addConnector
in interface BrokerViewMBean
Exception
public String addNetworkConnector(String discoveryAddress) throws Exception
addNetworkConnector
in interface BrokerViewMBean
Exception
public boolean removeConnector(String connectorName) throws Exception
removeConnector
in interface BrokerViewMBean
Exception
public boolean removeNetworkConnector(String connectorName) throws Exception
removeNetworkConnector
in interface BrokerViewMBean
Exception
public void addTopic(String name) throws Exception
BrokerViewMBean
addTopic
in interface BrokerViewMBean
name
- The name of the TopicException
public void addQueue(String name) throws Exception
BrokerViewMBean
addQueue
in interface BrokerViewMBean
name
- The name of the QueueException
public void removeTopic(String name) throws Exception
BrokerViewMBean
removeTopic
in interface BrokerViewMBean
name
- The name of the TopicException
public void removeQueue(String name) throws Exception
BrokerViewMBean
removeQueue
in interface BrokerViewMBean
name
- The name of the QueueException
public ObjectName createDurableSubscriber(String clientId, String subscriberName, String topicName, String selector) throws Exception
BrokerViewMBean
createDurableSubscriber
in interface BrokerViewMBean
clientId
- the JMS client IDsubscriberName
- the durable subscriber nametopicName
- the name of the topic to subscribe toselector
- a selector or nullException
public void destroyDurableSubscriber(String clientId, String subscriberName) throws Exception
BrokerViewMBean
destroyDurableSubscriber
in interface BrokerViewMBean
clientId
- the JMS client IDsubscriberName
- the durable subscriber nameException
public void reloadLog4jProperties() throws Throwable
BrokerViewMBean
reloadLog4jProperties
in interface BrokerViewMBean
Throwable
public String getOpenWireURL()
getOpenWireURL
in interface BrokerViewMBean
public String getStompURL()
getStompURL
in interface BrokerViewMBean
public String getSslURL()
getSslURL
in interface BrokerViewMBean
public String getStompSslURL()
getStompSslURL
in interface BrokerViewMBean
public String getVMURL()
getVMURL
in interface BrokerViewMBean
public String getDataDirectory()
getDataDirectory
in interface BrokerViewMBean
public ObjectName getJMSJobScheduler()
getJMSJobScheduler
in interface BrokerViewMBean
public void setJMSJobScheduler(ObjectName name)
Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.