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 String getUptime()
getUptime
in interface BrokerViewMBean
public long getUptimeMillis()
getUptimeMillis
in interface BrokerViewMBean
public int getCurrentConnectionsCount()
getCurrentConnectionsCount
in interface BrokerViewMBean
public long getTotalConnectionsCount()
getTotalConnectionsCount
in interface BrokerViewMBean
public void gc() throws Exception
BrokerViewMBean
gc
in interface BrokerViewMBean
Exception
public void stop() throws Exception
BrokerViewMBean
stop
in interface BrokerViewMBean
stop
in interface Service
Exception
public void restart() throws Exception
BrokerViewMBean
restart
in interface BrokerViewMBean
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 getAverageMessageSize()
getAverageMessageSize
in interface BrokerViewMBean
public long getMaxMessageSize()
getMaxMessageSize
in interface BrokerViewMBean
public long getMinMessageSize()
getMinMessageSize
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 long getJobSchedulerStoreLimit()
getJobSchedulerStoreLimit
in interface BrokerViewMBean
public int getJobSchedulerStorePercentUsage()
getJobSchedulerStorePercentUsage
in interface BrokerViewMBean
public void setStoreLimit(long limit)
setStoreLimit
in interface BrokerViewMBean
public void setTempLimit(long limit)
setTempLimit
in interface BrokerViewMBean
public void setJobSchedulerStoreLimit(long limit)
setJobSchedulerStoreLimit
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 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 String queryQueues(String filter, int page, int pageSize) throws IOException
BrokerViewMBean
DestinationsViewFilter
for more informationqueryQueues
in interface BrokerViewMBean
IOException
public String queryTopics(String filter, int page, int pageSize) throws IOException
BrokerViewMBean
DestinationsViewFilter
for more informationqueryTopics
in interface BrokerViewMBean
IOException
public CompositeData[] browseQueue(String queueName) throws OpenDataException, MalformedObjectNameException
browseQueue
in interface BrokerViewMBean
OpenDataException
MalformedObjectNameException
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 Map<String,String> getTransportConnectors()
getTransportConnectors
in interface BrokerViewMBean
public String getTransportConnectorByType(String type)
getTransportConnectorByType
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)
public boolean isSlave()
isSlave
in interface BrokerViewMBean
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.