public class BrokerView extends java.lang.Object implements BrokerViewMBean
Constructor and Description |
---|
BrokerView(BrokerService brokerService,
ManagedRegionBroker managedBroker) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
addConnector(java.lang.String discoveryAddress) |
java.lang.String |
addNetworkConnector(java.lang.String discoveryAddress) |
void |
addQueue(java.lang.String name)
Adds a Queue destination to the broker.
|
void |
addTopic(java.lang.String name)
Adds a Topic destination to the broker.
|
javax.management.ObjectName |
createDurableSubscriber(java.lang.String clientId,
java.lang.String subscriberName,
java.lang.String topicName,
java.lang.String selector)
Creates a new durable topic subscriber
|
void |
destroyDurableSubscriber(java.lang.String clientId,
java.lang.String subscriberName)
Destroys a durable subscriber
|
void |
disableStatistics() |
void |
enableStatistics() |
void |
gc()
The Broker will flush it's caches so that the garbage collector can
reclaim more memory.
|
ManagedRegionBroker |
getBroker() |
java.lang.String |
getBrokerId() |
java.lang.String |
getBrokerName() |
java.lang.String |
getBrokerVersion() |
java.lang.String |
getDataDirectory() |
javax.management.ObjectName[] |
getDurableTopicSubscribers() |
javax.management.ObjectName[] |
getDynamicDestinationProducers() |
javax.management.ObjectName[] |
getInactiveDurableTopicSubscribers() |
javax.management.ObjectName |
getJMSJobScheduler() |
long |
getMemoryLimit() |
int |
getMemoryPercentUsage() |
java.lang.String |
getOpenWireURL() |
javax.management.ObjectName[] |
getQueueProducers() |
javax.management.ObjectName[] |
getQueues() |
javax.management.ObjectName[] |
getQueueSubscribers() |
java.lang.String |
getSslURL() |
java.lang.String |
getStompSslURL() |
java.lang.String |
getStompURL() |
long |
getStoreLimit() |
int |
getStorePercentUsage() |
long |
getTempLimit() |
javax.management.ObjectName[] |
getTemporaryQueueProducers() |
javax.management.ObjectName[] |
getTemporaryQueues() |
javax.management.ObjectName[] |
getTemporaryQueueSubscribers() |
javax.management.ObjectName[] |
getTemporaryTopicProducers() |
javax.management.ObjectName[] |
getTemporaryTopics() |
javax.management.ObjectName[] |
getTemporaryTopicSubscribers() |
int |
getTempPercentUsage() |
javax.management.ObjectName[] |
getTopicProducers() |
javax.management.ObjectName[] |
getTopics() |
javax.management.ObjectName[] |
getTopicSubscribers() |
long |
getTotalConsumerCount() |
long |
getTotalDequeueCount() |
long |
getTotalEnqueueCount() |
long |
getTotalMessageCount() |
long |
getTotalMessagesCached() |
long |
getTotalProducerCount() |
java.lang.String |
getVMURL() |
boolean |
isPersistent() |
boolean |
isSlave() |
boolean |
isStatisticsEnabled() |
void |
reloadLog4jProperties()
Reloads log4j.properties from the classpath.
|
boolean |
removeConnector(java.lang.String connectorName) |
boolean |
removeNetworkConnector(java.lang.String connectorName) |
void |
removeQueue(java.lang.String name)
Removes a Queue destination from the broker.
|
void |
removeTopic(java.lang.String name)
Removes a Topic destination from the broker.
|
void |
resetStatistics() |
void |
setBroker(ManagedRegionBroker broker) |
void |
setJMSJobScheduler(javax.management.ObjectName name) |
void |
setMemoryLimit(long limit) |
void |
setStoreLimit(long limit) |
void |
setTempLimit(long limit) |
void |
start() |
void |
stop()
Stop the broker and all it's components.
|
void |
stopGracefully(java.lang.String connectorName,
java.lang.String queueName,
long timeout,
long pollInterval) |
void |
terminateJVM(int exitCode)
Shuts down the JVM.
|
public BrokerView(BrokerService brokerService, ManagedRegionBroker managedBroker) throws java.lang.Exception
java.lang.Exception
public ManagedRegionBroker getBroker()
public void setBroker(ManagedRegionBroker broker)
public java.lang.String getBrokerId()
getBrokerId
in interface BrokerViewMBean
public java.lang.String getBrokerName()
getBrokerName
in interface BrokerViewMBean
public java.lang.String getBrokerVersion()
getBrokerVersion
in interface BrokerViewMBean
public void gc() throws java.lang.Exception
BrokerViewMBean
gc
in interface BrokerViewMBean
java.lang.Exception
public void start() throws java.lang.Exception
public void stop() throws java.lang.Exception
BrokerViewMBean
stop
in interface BrokerViewMBean
stop
in interface Service
java.lang.Exception
public void stopGracefully(java.lang.String connectorName, java.lang.String queueName, long timeout, long pollInterval) throws java.lang.Exception
stopGracefully
in interface BrokerViewMBean
java.lang.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 javax.management.ObjectName[] getTopics()
getTopics
in interface BrokerViewMBean
public javax.management.ObjectName[] getQueues()
getQueues
in interface BrokerViewMBean
public javax.management.ObjectName[] getTemporaryTopics()
getTemporaryTopics
in interface BrokerViewMBean
public javax.management.ObjectName[] getTemporaryQueues()
getTemporaryQueues
in interface BrokerViewMBean
public javax.management.ObjectName[] getTopicSubscribers()
getTopicSubscribers
in interface BrokerViewMBean
public javax.management.ObjectName[] getDurableTopicSubscribers()
getDurableTopicSubscribers
in interface BrokerViewMBean
public javax.management.ObjectName[] getQueueSubscribers()
getQueueSubscribers
in interface BrokerViewMBean
public javax.management.ObjectName[] getTemporaryTopicSubscribers()
getTemporaryTopicSubscribers
in interface BrokerViewMBean
public javax.management.ObjectName[] getTemporaryQueueSubscribers()
getTemporaryQueueSubscribers
in interface BrokerViewMBean
public javax.management.ObjectName[] getInactiveDurableTopicSubscribers()
getInactiveDurableTopicSubscribers
in interface BrokerViewMBean
public javax.management.ObjectName[] getTopicProducers()
getTopicProducers
in interface BrokerViewMBean
public javax.management.ObjectName[] getQueueProducers()
getQueueProducers
in interface BrokerViewMBean
public javax.management.ObjectName[] getTemporaryTopicProducers()
getTemporaryTopicProducers
in interface BrokerViewMBean
public javax.management.ObjectName[] getTemporaryQueueProducers()
getTemporaryQueueProducers
in interface BrokerViewMBean
public javax.management.ObjectName[] getDynamicDestinationProducers()
getDynamicDestinationProducers
in interface BrokerViewMBean
public java.lang.String addConnector(java.lang.String discoveryAddress) throws java.lang.Exception
addConnector
in interface BrokerViewMBean
java.lang.Exception
public java.lang.String addNetworkConnector(java.lang.String discoveryAddress) throws java.lang.Exception
addNetworkConnector
in interface BrokerViewMBean
java.lang.Exception
public boolean removeConnector(java.lang.String connectorName) throws java.lang.Exception
removeConnector
in interface BrokerViewMBean
java.lang.Exception
public boolean removeNetworkConnector(java.lang.String connectorName) throws java.lang.Exception
removeNetworkConnector
in interface BrokerViewMBean
java.lang.Exception
public void addTopic(java.lang.String name) throws java.lang.Exception
BrokerViewMBean
addTopic
in interface BrokerViewMBean
name
- The name of the Topicjava.lang.Exception
public void addQueue(java.lang.String name) throws java.lang.Exception
BrokerViewMBean
addQueue
in interface BrokerViewMBean
name
- The name of the Queuejava.lang.Exception
public void removeTopic(java.lang.String name) throws java.lang.Exception
BrokerViewMBean
removeTopic
in interface BrokerViewMBean
name
- The name of the Topicjava.lang.Exception
public void removeQueue(java.lang.String name) throws java.lang.Exception
BrokerViewMBean
removeQueue
in interface BrokerViewMBean
name
- The name of the Queuejava.lang.Exception
public javax.management.ObjectName createDurableSubscriber(java.lang.String clientId, java.lang.String subscriberName, java.lang.String topicName, java.lang.String selector) throws java.lang.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 nulljava.lang.Exception
public void destroyDurableSubscriber(java.lang.String clientId, java.lang.String subscriberName) throws java.lang.Exception
BrokerViewMBean
destroyDurableSubscriber
in interface BrokerViewMBean
clientId
- the JMS client IDsubscriberName
- the durable subscriber namejava.lang.Exception
public void reloadLog4jProperties() throws java.lang.Throwable
BrokerViewMBean
reloadLog4jProperties
in interface BrokerViewMBean
java.lang.Throwable
public java.lang.String getOpenWireURL()
getOpenWireURL
in interface BrokerViewMBean
public java.lang.String getStompURL()
getStompURL
in interface BrokerViewMBean
public java.lang.String getSslURL()
getSslURL
in interface BrokerViewMBean
public java.lang.String getStompSslURL()
getStompSslURL
in interface BrokerViewMBean
public java.lang.String getVMURL()
getVMURL
in interface BrokerViewMBean
public java.lang.String getDataDirectory()
getDataDirectory
in interface BrokerViewMBean
public javax.management.ObjectName getJMSJobScheduler()
getJMSJobScheduler
in interface BrokerViewMBean
public void setJMSJobScheduler(javax.management.ObjectName name)
Copyright © 2005-2017. All Rights Reserved.