Package | Description |
---|---|
org.apache.activemq.broker.jmx |
JMX MBeans for the broker and its core connectors.
|
Modifier and Type | Method and Description |
---|---|
void |
AbortSlowConsumerStrategyViewMBean.abortConnection(javax.management.ObjectName consumerToAbort) |
void |
AbortSlowConsumerStrategyViewMBean.abortConnection(java.lang.String objectNameOfConsumerToAbort) |
void |
AbortSlowConsumerStrategyViewMBean.abortConsumer(javax.management.ObjectName consumerToAbort) |
void |
AbortSlowConsumerStrategyViewMBean.abortConsumer(java.lang.String objectNameOfConsumerToAbort) |
java.lang.String |
BrokerViewMBean.addConnector(java.lang.String discoveryAddress) |
java.lang.String |
BrokerViewMBean.addNetworkConnector(java.lang.String discoveryAddress) |
void |
BrokerViewMBean.addQueue(java.lang.String name)
Adds a Queue destination to the broker.
|
void |
BrokerViewMBean.addTopic(java.lang.String name)
Adds a Topic destination to the broker.
|
javax.management.openmbean.CompositeData[] |
DestinationViewMBean.browse() |
javax.management.openmbean.CompositeData[] |
DestinationViewMBean.browse(java.lang.String selector) |
javax.management.openmbean.TabularData |
DestinationViewMBean.browseAsTable() |
javax.management.openmbean.TabularData |
DestinationViewMBean.browseAsTable(java.lang.String selector) |
java.util.List<?> |
DestinationViewMBean.browseMessages()
Browses the current destination returning a list of messages
|
java.util.List<?> |
DestinationViewMBean.browseMessages(java.lang.String selector)
Browses the current destination with the given selector returning a list
of messages
|
int |
QueueViewMBean.copyMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName)
Copies the messages matching the given selector
|
int |
QueueViewMBean.copyMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName,
int maximumMessages)
Copies the messages matching the given selector up to the maximum number
of matched messages
|
boolean |
QueueViewMBean.copyMessageTo(java.lang.String messageId,
java.lang.String destinationName)
Copies a given message to another destination.
|
javax.management.ObjectName |
BrokerViewMBean.createDurableSubscriber(java.lang.String clientId,
java.lang.String subscriberName,
java.lang.String topicName,
java.lang.String selector)
Creates a new durable topic subscriber
|
int |
QueueViewMBean.cursorSize() |
void |
BrokerViewMBean.destroyDurableSubscriber(java.lang.String clientId,
java.lang.String subscriberName)
Destroys a durable subscriber
|
void |
BrokerViewMBean.disableStatistics() |
void |
ConnectorViewMBean.disableStatistics()
disable statistics gathering
|
boolean |
QueueViewMBean.doesCursorHaveMessagesBuffered() |
boolean |
QueueViewMBean.doesCursorHaveSpace() |
void |
BrokerViewMBean.enableStatistics() |
void |
ConnectorViewMBean.enableStatistics()
enable statistics gathering
|
void |
BrokerViewMBean.gc()
The Broker will fush it's caches so that the garbage collector can
recalaim more memory.
|
javax.management.openmbean.TabularData |
JobSchedulerViewMBean.getAllJobs()
Get all the outstanding Jobs
|
javax.management.openmbean.TabularData |
JobSchedulerViewMBean.getAllJobs(java.lang.String start,
java.lang.String finish)
Get all outstanding jobs due to run between start and finish
|
double |
DestinationViewMBean.getAverageEnqueueTime() |
long |
DestinationViewMBean.getBlockedProducerWarningInterval() |
java.lang.String |
BrokerViewMBean.getBrokerId() |
java.lang.String |
BrokerViewMBean.getBrokerName() |
java.lang.String |
BrokerViewMBean.getBrokerVersion() |
long |
AbortSlowConsumerStrategyViewMBean.getCheckPeriod() |
java.lang.String |
SubscriptionViewMBean.getClientId() |
java.lang.String |
SubscriptionViewMBean.getConnectionId() |
long |
DestinationViewMBean.getConsumerCount()
Returns the number of consumers subscribed this destination.
|
long |
QueueViewMBean.getCursorMemoryUsage() |
int |
QueueViewMBean.getCursorPercentUsage() |
java.lang.String |
BrokerViewMBean.getDataDirectory() |
long |
DestinationViewMBean.getDequeueCount()
Returns the number of messages that have been acknowledged from the
destination.
|
long |
SubscriptionViewMBean.getDequeueCounter() |
java.lang.String |
SubscriptionViewMBean.getDestinationName() |
int |
TopicSubscriptionViewMBean.getDiscardedCount() |
long |
DestinationViewMBean.getDispatchCount()
Returns the number of messages that have been delivered (potentially not
acknowledged) to consumers.
|
long |
SubscriptionViewMBean.getDispatchedCounter() |
int |
SubscriptionViewMBean.getDispatchedQueueSize() |
javax.management.ObjectName[] |
BrokerViewMBean.getDurableTopicSubscribers() |
long |
DestinationViewMBean.getEnqueueCount()
Returns the number of messages that have been sent to the destination.
|
long |
SubscriptionViewMBean.getEnqueueCounter() |
long |
DestinationViewMBean.getExpiredCount()
Returns the number of messages that have expired
|
javax.management.ObjectName[] |
BrokerViewMBean.getInactiveDurableTopicSubscribers() |
long |
DestinationViewMBean.getInFlightCount()
Returns the number of messages that have been dispatched but not
acknowledged
|
javax.management.ObjectName |
BrokerViewMBean.getJMSJobScheduler() |
int |
DestinationViewMBean.getMaxAuditDepth() |
long |
DestinationViewMBean.getMaxEnqueueTime() |
int |
SubscriptionViewMBean.getMaximumPendingMessageLimit() |
int |
TopicSubscriptionViewMBean.getMaximumPendingQueueSize() |
int |
DestinationViewMBean.getMaxPageSize() |
int |
DestinationViewMBean.getMaxProducersToAudit() |
long |
AbortSlowConsumerStrategyViewMBean.getMaxSlowCount() |
long |
AbortSlowConsumerStrategyViewMBean.getMaxSlowDuration() |
long |
DestinationViewMBean.getMemoryLimit() |
long |
BrokerViewMBean.getMemoryLimit() |
int |
DestinationViewMBean.getMemoryPercentUsage() |
int |
BrokerViewMBean.getMemoryPercentUsage() |
float |
DestinationViewMBean.getMemoryUsagePortion() |
javax.management.openmbean.CompositeData |
QueueViewMBean.getMessage(java.lang.String messageId)
Retrieve a message from the destination's queue.
|
int |
SubscriptionViewMBean.getMessageCountAwaitingAcknowledge()
The same as the number of messages dispatched -
making it explicit
|
long |
DestinationViewMBean.getMinEnqueueTime() |
java.lang.String |
DestinationViewMBean.getName()
Returns the name of this destination
|
javax.management.openmbean.TabularData |
JobSchedulerViewMBean.getNextScheduleJobs()
Get all the jobs scheduled to run next
|
java.lang.String |
JobSchedulerViewMBean.getNextScheduleTime()
Get the next time jobs will be fired
|
java.lang.String |
BrokerViewMBean.getOpenWireURL() |
int |
SubscriptionViewMBean.getPendingQueueSize() |
int |
SubscriptionViewMBean.getPrefetchSize() |
byte |
SubscriptionViewMBean.getPriority() |
long |
DestinationViewMBean.getProducerCount() |
javax.management.ObjectName[] |
BrokerViewMBean.getQueues() |
long |
DestinationViewMBean.getQueueSize()
Returns the number of messages in this destination which are yet to be
consumed
|
javax.management.ObjectName[] |
BrokerViewMBean.getQueueSubscribers() |
java.lang.String |
ConnectionViewMBean.getRemoteAddress()
Returns the source address for this connection
|
java.lang.String |
SubscriptionViewMBean.getSelector() |
long |
SubscriptionViewMBean.getSessionId() |
javax.management.openmbean.TabularData |
AbortSlowConsumerStrategyViewMBean.getSlowConsumers() |
javax.management.ObjectName |
DestinationViewMBean.getSlowConsumerStrategy()
Returns the slow consumer strategy MBean for this destination
|
java.lang.String |
BrokerViewMBean.getSslURL() |
java.lang.String |
BrokerViewMBean.getStompSslURL() |
java.lang.String |
BrokerViewMBean.getStompURL() |
long |
BrokerViewMBean.getStoreLimit() |
int |
BrokerViewMBean.getStorePercentUsage() |
long |
SubscriptionViewMBean.getSubcriptionId() |
java.lang.String |
SubscriptionViewMBean.getSubcriptionName() |
javax.management.ObjectName[] |
DestinationViewMBean.getSubscriptions()
Returns all the current subscription MBeans matching this destination
|
long |
BrokerViewMBean.getTempLimit() |
javax.management.ObjectName[] |
BrokerViewMBean.getTemporaryQueues() |
javax.management.ObjectName[] |
BrokerViewMBean.getTemporaryQueueSubscribers() |
javax.management.ObjectName[] |
BrokerViewMBean.getTemporaryTopics() |
javax.management.ObjectName[] |
BrokerViewMBean.getTemporaryTopicSubscribers() |
int |
BrokerViewMBean.getTempPercentUsage() |
javax.management.ObjectName[] |
BrokerViewMBean.getTopics() |
javax.management.ObjectName[] |
BrokerViewMBean.getTopicSubscribers() |
long |
BrokerViewMBean.getTotalConsumerCount() |
long |
BrokerViewMBean.getTotalDequeueCount() |
long |
BrokerViewMBean.getTotalEnqueueCount() |
long |
BrokerViewMBean.getTotalMessageCount() |
java.lang.String |
BrokerViewMBean.getVMURL() |
boolean |
SubscriptionViewMBean.isActive() |
boolean |
ConnectionViewMBean.isActive() |
boolean |
ConnectionViewMBean.isBlocked() |
boolean |
QueueViewMBean.isCacheEnabled() |
boolean |
ConnectionViewMBean.isConnected() |
boolean |
QueueViewMBean.isCursorFull() |
boolean |
SubscriptionViewMBean.isDestinationQueue() |
boolean |
SubscriptionViewMBean.isDestinationTemporary() |
boolean |
SubscriptionViewMBean.isDestinationTopic() |
boolean |
SubscriptionViewMBean.isDurable() |
boolean |
SubscriptionViewMBean.isExclusive() |
boolean |
SubscriptionViewMBean.isMatchingQueue(java.lang.String queueName)
Returns true if this subscription (which may be using wildcards) matches the given queue name
|
boolean |
SubscriptionViewMBean.isMatchingTopic(java.lang.String topicName)
Returns true if this subscription (which may be using wildcards) matches the given topic name
|
boolean |
SubscriptionViewMBean.isNoLocal() |
boolean |
BrokerViewMBean.isPersistent() |
boolean |
DestinationViewMBean.isPrioritizedMessages() |
boolean |
DestinationViewMBean.isProducerFlowControl() |
boolean |
SubscriptionViewMBean.isRetroactive() |
boolean |
BrokerViewMBean.isSlave() |
boolean |
ConnectionViewMBean.isSlow() |
boolean |
BrokerViewMBean.isStatisticsEnabled() |
boolean |
ConnectorViewMBean.isStatisticsEnabled()
Returns true if statistics is enabled
|
boolean |
DestinationViewMBean.isUseCache() |
int |
QueueViewMBean.moveMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName)
Moves the messages matching the given selector
|
int |
QueueViewMBean.moveMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName,
int maximumMessages)
Moves the messages matching the given selector up to the maximum number
of matched messages
|
boolean |
QueueViewMBean.moveMessageTo(java.lang.String messageId,
java.lang.String destinationName)
Moves the message to another destination.
|
void |
QueueViewMBean.purge()
Removes all of the messages in the queue.
|
void |
BrokerViewMBean.reloadLog4jProperties()
Reloads log4j.properties from the classpath.
|
void |
JobSchedulerViewMBean.removeAllJobs()
remove all the Jobs from the scheduler
|
void |
JobSchedulerViewMBean.removeAllJobs(java.lang.String start,
java.lang.String finish)
remove all the Jobs from the scheduler that are due between the start and finish times
|
boolean |
BrokerViewMBean.removeConnector(java.lang.String connectorName) |
void |
JobSchedulerViewMBean.removeJob(java.lang.String jobId)
remove a job with the matching jobId
|
void |
JobSchedulerViewMBean.removeJobAtScheduledTime(java.lang.String time)
remove all jobs scheduled to run at this time
|
int |
QueueViewMBean.removeMatchingMessages(java.lang.String selector)
Removes the messages matching the given selector
|
int |
QueueViewMBean.removeMatchingMessages(java.lang.String selector,
int maximumMessages)
Removes the messages matching the given selector up to the maximum number
of matched messages
|
boolean |
QueueViewMBean.removeMessage(java.lang.String messageId)
Removes a message from the queue.
|
boolean |
BrokerViewMBean.removeNetworkConnector(java.lang.String connectorName) |
void |
BrokerViewMBean.removeQueue(java.lang.String name)
Removes a Queue destination from the broker.
|
void |
BrokerViewMBean.removeTopic(java.lang.String name)
Removes a Topic destination from the broker.
|
void |
DestinationViewMBean.resetStatistics()
Resets the managment counters.
|
void |
BrokerViewMBean.resetStatistics() |
void |
ConnectorViewMBean.resetStatistics()
Resets the statistics
|
void |
ConnectionViewMBean.resetStatistics()
Resets the statistics
|
boolean |
QueueViewMBean.retryMessage(java.lang.String messageId)
Moves a message back to its original destination
|
java.lang.String |
DestinationViewMBean.sendTextMessage(java.util.Map<?,?> headers,
java.lang.String body)
Sends a TextMesage to the destination.
|
java.lang.String |
DestinationViewMBean.sendTextMessage(java.util.Map<?,?> headers,
java.lang.String body,
java.lang.String user,
java.lang.String password) |
java.lang.String |
DestinationViewMBean.sendTextMessage(java.lang.String body)
Sends a TextMesage to the destination.
|
java.lang.String |
DestinationViewMBean.sendTextMessage(java.lang.String body,
java.lang.String user,
java.lang.String password)
Sends a TextMesage to the destination.
|
void |
AbortSlowConsumerStrategyViewMBean.setMaxSlowCount(long maxSlowCount) |
void |
AbortSlowConsumerStrategyViewMBean.setMaxSlowDuration(long maxSlowDuration) |
void |
BrokerViewMBean.stop()
Stop the broker and all it's components.
|
void |
BrokerViewMBean.stopGracefully(java.lang.String connectorName,
java.lang.String queueName,
long timeout,
long pollInterval) |
void |
BrokerViewMBean.terminateJVM(int exitCode)
Shuts down the JVM.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
BrokerViewMBean.addConnector(java.lang.String discoveryAddress) |
java.lang.String |
BrokerViewMBean.addNetworkConnector(java.lang.String discoveryAddress) |
void |
BrokerViewMBean.addQueue(java.lang.String name)
Adds a Queue destination to the broker.
|
void |
BrokerViewMBean.addTopic(java.lang.String name)
Adds a Topic destination to the broker.
|
javax.management.openmbean.CompositeData[] |
DestinationViewMBean.browse(java.lang.String selector) |
javax.management.openmbean.TabularData |
DestinationViewMBean.browseAsTable(java.lang.String selector) |
int |
QueueViewMBean.copyMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName)
Copies the messages matching the given selector
|
int |
QueueViewMBean.copyMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName)
Copies the messages matching the given selector
|
int |
QueueViewMBean.copyMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName,
int maximumMessages)
Copies the messages matching the given selector up to the maximum number
of matched messages
|
int |
QueueViewMBean.copyMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName,
int maximumMessages)
Copies the messages matching the given selector up to the maximum number
of matched messages
|
int |
QueueViewMBean.copyMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName,
int maximumMessages)
Copies the messages matching the given selector up to the maximum number
of matched messages
|
boolean |
QueueViewMBean.copyMessageTo(java.lang.String messageId,
java.lang.String destinationName)
Copies a given message to another destination.
|
boolean |
QueueViewMBean.copyMessageTo(java.lang.String messageId,
java.lang.String destinationName)
Copies a given message to another destination.
|
javax.management.ObjectName |
BrokerViewMBean.createDurableSubscriber(java.lang.String clientId,
java.lang.String subscriberName,
java.lang.String topicName,
java.lang.String selector)
Creates a new durable topic subscriber
|
javax.management.ObjectName |
BrokerViewMBean.createDurableSubscriber(java.lang.String clientId,
java.lang.String subscriberName,
java.lang.String topicName,
java.lang.String selector)
Creates a new durable topic subscriber
|
javax.management.ObjectName |
BrokerViewMBean.createDurableSubscriber(java.lang.String clientId,
java.lang.String subscriberName,
java.lang.String topicName,
java.lang.String selector)
Creates a new durable topic subscriber
|
javax.management.ObjectName |
BrokerViewMBean.createDurableSubscriber(java.lang.String clientId,
java.lang.String subscriberName,
java.lang.String topicName,
java.lang.String selector)
Creates a new durable topic subscriber
|
void |
BrokerViewMBean.destroyDurableSubscriber(java.lang.String clientId,
java.lang.String subscriberName)
Destroys a durable subscriber
|
void |
BrokerViewMBean.destroyDurableSubscriber(java.lang.String clientId,
java.lang.String subscriberName)
Destroys a durable subscriber
|
javax.management.openmbean.TabularData |
JobSchedulerViewMBean.getAllJobs(java.lang.String start,
java.lang.String finish)
Get all outstanding jobs due to run between start and finish
|
javax.management.openmbean.TabularData |
JobSchedulerViewMBean.getAllJobs(java.lang.String start,
java.lang.String finish)
Get all outstanding jobs due to run between start and finish
|
javax.management.openmbean.CompositeData |
QueueViewMBean.getMessage(java.lang.String messageId)
Retrieve a message from the destination's queue.
|
int |
QueueViewMBean.moveMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName)
Moves the messages matching the given selector
|
int |
QueueViewMBean.moveMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName)
Moves the messages matching the given selector
|
int |
QueueViewMBean.moveMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName,
int maximumMessages)
Moves the messages matching the given selector up to the maximum number
of matched messages
|
int |
QueueViewMBean.moveMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName,
int maximumMessages)
Moves the messages matching the given selector up to the maximum number
of matched messages
|
int |
QueueViewMBean.moveMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName,
int maximumMessages)
Moves the messages matching the given selector up to the maximum number
of matched messages
|
boolean |
QueueViewMBean.moveMessageTo(java.lang.String messageId,
java.lang.String destinationName)
Moves the message to another destination.
|
boolean |
QueueViewMBean.moveMessageTo(java.lang.String messageId,
java.lang.String destinationName)
Moves the message to another destination.
|
void |
JobSchedulerViewMBean.removeAllJobs(java.lang.String start,
java.lang.String finish)
remove all the Jobs from the scheduler that are due between the start and finish times
|
void |
JobSchedulerViewMBean.removeAllJobs(java.lang.String start,
java.lang.String finish)
remove all the Jobs from the scheduler that are due between the start and finish times
|
boolean |
BrokerViewMBean.removeConnector(java.lang.String connectorName) |
void |
JobSchedulerViewMBean.removeJob(java.lang.String jobId)
remove a job with the matching jobId
|
void |
JobSchedulerViewMBean.removeJobAtScheduledTime(java.lang.String time)
remove all jobs scheduled to run at this time
|
int |
QueueViewMBean.removeMatchingMessages(java.lang.String selector)
Removes the messages matching the given selector
|
int |
QueueViewMBean.removeMatchingMessages(java.lang.String selector,
int maximumMessages)
Removes the messages matching the given selector up to the maximum number
of matched messages
|
int |
QueueViewMBean.removeMatchingMessages(java.lang.String selector,
int maximumMessages)
Removes the messages matching the given selector up to the maximum number
of matched messages
|
boolean |
QueueViewMBean.removeMessage(java.lang.String messageId)
Removes a message from the queue.
|
boolean |
BrokerViewMBean.removeNetworkConnector(java.lang.String connectorName) |
void |
BrokerViewMBean.removeQueue(java.lang.String name)
Removes a Queue destination from the broker.
|
void |
BrokerViewMBean.removeTopic(java.lang.String name)
Removes a Topic destination from the broker.
|
boolean |
QueueViewMBean.retryMessage(java.lang.String messageId)
Moves a message back to its original destination
|
java.lang.String |
DestinationViewMBean.sendTextMessage(java.util.Map<?,?> headers,
java.lang.String body)
Sends a TextMesage to the destination.
|
java.lang.String |
DestinationViewMBean.sendTextMessage(java.util.Map<?,?> headers,
java.lang.String body)
Sends a TextMesage to the destination.
|
java.lang.String |
DestinationViewMBean.sendTextMessage(java.util.Map<?,?> headers,
java.lang.String body,
java.lang.String user,
java.lang.String password) |
java.lang.String |
DestinationViewMBean.sendTextMessage(java.util.Map<?,?> headers,
java.lang.String body,
java.lang.String user,
java.lang.String password) |
java.lang.String |
DestinationViewMBean.sendTextMessage(java.util.Map<?,?> headers,
java.lang.String body,
java.lang.String user,
java.lang.String password) |
java.lang.String |
DestinationViewMBean.sendTextMessage(java.util.Map<?,?> headers,
java.lang.String body,
java.lang.String user,
java.lang.String password) |
java.lang.String |
DestinationViewMBean.sendTextMessage(java.lang.String body)
Sends a TextMesage to the destination.
|
java.lang.String |
DestinationViewMBean.sendTextMessage(java.lang.String body,
java.lang.String user,
java.lang.String password)
Sends a TextMesage to the destination.
|
java.lang.String |
DestinationViewMBean.sendTextMessage(java.lang.String body,
java.lang.String user,
java.lang.String password)
Sends a TextMesage to the destination.
|
java.lang.String |
DestinationViewMBean.sendTextMessage(java.lang.String body,
java.lang.String user,
java.lang.String password)
Sends a TextMesage to the destination.
|
void |
DestinationViewMBean.setBlockedProducerWarningInterval(long blockedProducerWarningInterval)
Set's the interval at which warnings about producers being blocked by
resource usage will be triggered.
|
void |
DestinationViewMBean.setMaxAuditDepth(int maxAuditDepth) |
void |
DestinationViewMBean.setMaxPageSize(int pageSize) |
void |
DestinationViewMBean.setMaxProducersToAudit(int maxProducersToAudit) |
void |
BrokerViewMBean.setMemoryLimit(long limit) |
void |
DestinationViewMBean.setMemoryUsagePortion(float value)
set the portion of memory from the broker memory limit for this destination
|
void |
DestinationViewMBean.setProducerFlowControl(boolean producerFlowControl) |
void |
SubscriptionViewMBean.setSelector(java.lang.String selector)
Attempts to change the current active selector on the subscription.
|
void |
BrokerViewMBean.setStoreLimit(long limit) |
void |
BrokerViewMBean.setTempLimit(long limit) |
void |
DestinationViewMBean.setUseCache(boolean value) |
void |
BrokerViewMBean.terminateJVM(int exitCode)
Shuts down the JVM.
|
Copyright © 2005-2012. All Rights Reserved.