Uses of Annotation Interface
org.apache.activemq.artemis.api.core.management.Operation
Packages that use Operation
-
Uses of Operation in org.apache.activemq.artemis.api.core.management
Methods in org.apache.activemq.artemis.api.core.management with annotations of type OperationModifier and TypeMethodDescriptionActiveMQServerControl.addAddressSettings
(String address, String addressSettingsConfigurationAsJson) adds a new address setting for a specific addressvoid
ActiveMQServerControl.addAddressSettings
(String addressMatch, String DLA, String expiryAddress, long expiryDelay, boolean lastValueQueue, int deliveryAttempts, long maxSizeBytes, int pageSizeBytes, int pageMaxCacheSize, long redeliveryDelay, double redeliveryMultiplier, long maxRedeliveryDelay, long redistributionDelay, boolean sendToDLAOnNoRoute, String addressFullMessagePolicy, long slowConsumerThreshold, long slowConsumerCheckPeriod, String slowConsumerPolicy, boolean autoCreateJmsQueues, boolean autoDeleteJmsQueues, boolean autoCreateJmsTopics, boolean autoDeleteJmsTopics) Deprecated.void
ActiveMQServerControl.addAddressSettings
(String addressMatch, String DLA, String expiryAddress, long expiryDelay, boolean lastValueQueue, int deliveryAttempts, long maxSizeBytes, int pageSizeBytes, int pageMaxCacheSize, long redeliveryDelay, double redeliveryMultiplier, long maxRedeliveryDelay, long redistributionDelay, boolean sendToDLAOnNoRoute, String addressFullMessagePolicy, long slowConsumerThreshold, long slowConsumerCheckPeriod, String slowConsumerPolicy, boolean autoCreateJmsQueues, boolean autoDeleteJmsQueues, boolean autoCreateJmsTopics, boolean autoDeleteJmsTopics, boolean autoCreateQueues, boolean autoDeleteQueues, boolean autoCreateAddresses, boolean autoDeleteAddresses) Deprecated.void
ActiveMQServerControl.addAddressSettings
(String addressMatch, String DLA, String expiryAddress, long expiryDelay, boolean lastValueQueue, int deliveryAttempts, long maxSizeBytes, int pageSizeBytes, int pageMaxCacheSize, long redeliveryDelay, double redeliveryMultiplier, long maxRedeliveryDelay, long redistributionDelay, boolean sendToDLAOnNoRoute, String addressFullMessagePolicy, long slowConsumerThreshold, long slowConsumerCheckPeriod, String slowConsumerPolicy, boolean autoCreateJmsQueues, boolean autoDeleteJmsQueues, boolean autoCreateJmsTopics, boolean autoDeleteJmsTopics, boolean autoCreateQueues, boolean autoDeleteQueues, boolean autoCreateAddresses, boolean autoDeleteAddresses, String configDeleteQueues, String configDeleteAddresses, long maxSizeBytesRejectThreshold, String defaultLastValueKey, boolean defaultNonDestructive, boolean defaultExclusiveQueue, boolean defaultGroupRebalance, int defaultGroupBuckets, String defaultGroupFirstKey, int defaultMaxConsumers, boolean defaultPurgeOnNoConsumers, int defaultConsumersBeforeDispatch, long defaultDelayBeforeDispatch, String defaultQueueRoutingType, String defaultAddressRoutingType, int defaultConsumerWindowSize, long defaultRingSize, boolean autoDeleteCreatedQueues, long autoDeleteQueuesDelay, long autoDeleteQueuesMessageCount, long autoDeleteAddressesDelay, double redeliveryCollisionAvoidanceFactor, long retroactiveMessageCount) Deprecated.void
ActiveMQServerControl.addAddressSettings
(String addressMatch, String DLA, String expiryAddress, long expiryDelay, boolean lastValueQueue, int deliveryAttempts, long maxSizeBytes, int pageSizeBytes, int pageMaxCacheSize, long redeliveryDelay, double redeliveryMultiplier, long maxRedeliveryDelay, long redistributionDelay, boolean sendToDLAOnNoRoute, String addressFullMessagePolicy, long slowConsumerThreshold, long slowConsumerCheckPeriod, String slowConsumerPolicy, boolean autoCreateJmsQueues, boolean autoDeleteJmsQueues, boolean autoCreateJmsTopics, boolean autoDeleteJmsTopics, boolean autoCreateQueues, boolean autoDeleteQueues, boolean autoCreateAddresses, boolean autoDeleteAddresses, String configDeleteQueues, String configDeleteAddresses, long maxSizeBytesRejectThreshold, String defaultLastValueKey, boolean defaultNonDestructive, boolean defaultExclusiveQueue, boolean defaultGroupRebalance, int defaultGroupBuckets, String defaultGroupFirstKey, int defaultMaxConsumers, boolean defaultPurgeOnNoConsumers, int defaultConsumersBeforeDispatch, long defaultDelayBeforeDispatch, String defaultQueueRoutingType, String defaultAddressRoutingType, int defaultConsumerWindowSize, long defaultRingSize, boolean autoDeleteCreatedQueues, long autoDeleteQueuesDelay, long autoDeleteQueuesMessageCount, long autoDeleteAddressesDelay, double redeliveryCollisionAvoidanceFactor, long retroactiveMessageCount, boolean autoCreateDeadLetterResources, String deadLetterQueuePrefix, String deadLetterQueueSuffix, boolean autoCreateExpiryResources, String expiryQueuePrefix, String expiryQueueSuffix) Deprecated.void
ActiveMQServerControl.addAddressSettings
(String addressMatch, String DLA, String expiryAddress, long expiryDelay, boolean lastValueQueue, int maxDeliveryAttempts, long maxSizeBytes, int pageSizeBytes, int pageCacheMaxSize, long redeliveryDelay, double redeliveryMultiplier, long maxRedeliveryDelay, long redistributionDelay, boolean sendToDLAOnNoRoute, String addressFullMessagePolicy, long slowConsumerThreshold, long slowConsumerCheckPeriod, String slowConsumerPolicy, boolean autoCreateJmsQueues, boolean autoDeleteJmsQueues, boolean autoCreateJmsTopics, boolean autoDeleteJmsTopics, boolean autoCreateQueues, boolean autoDeleteQueues, boolean autoCreateAddresses, boolean autoDeleteAddresses, String configDeleteQueues, String configDeleteAddresses, long maxSizeBytesRejectThreshold, String defaultLastValueKey, boolean defaultNonDestructive, boolean defaultExclusiveQueue, boolean defaultGroupRebalance, int defaultGroupBuckets, String defaultGroupFirstKey, int defaultMaxConsumers, boolean defaultPurgeOnNoConsumers, int defaultConsumersBeforeDispatch, long defaultDelayBeforeDispatch, String defaultQueueRoutingType, String defaultAddressRoutingType, int defaultConsumerWindowSize, long defaultRingSize, boolean autoDeleteCreatedQueues, long autoDeleteQueuesDelay, long autoDeleteQueuesMessageCount, long autoDeleteAddressesDelay, double redeliveryCollisionAvoidanceFactor, long retroactiveMessageCount, boolean autoCreateDeadLetterResources, String deadLetterQueuePrefix, String deadLetterQueueSuffix, boolean autoCreateExpiryResources, String expiryQueuePrefix, String expiryQueueSuffix, long minExpiryDelay, long maxExpiryDelay, boolean enableMetrics) Deprecated.void
ActiveMQServerControl.addConnector
(String name, String url) void
ActiveMQServerControl.addSecuritySettings
(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles) void
ActiveMQServerControl.addSecuritySettings
(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles, String browseRoles) void
ActiveMQServerControl.addSecuritySettings
(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles, String browseRoles, String createAddressRoles, String deleteAddressRoles) void
ActiveMQServerControl.addSecuritySettings
(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles, String browseRoles, String createAddressRoles, String deleteAddressRoles, String viewRoles, String editRoles) void
Add a user (only applicable when using the JAAS PropertiesLoginModule or the ActiveMQBasicSecurityManager)boolean
AddressControl.block()
Blocks message production to this address by limiting creditQueueControl.browse()
QueueControl.browse
(int page, int pageSize) boolean
QueueControl.changeMessagePriority
(long messageID, int newPriority) Changes the message's priority corresponding to the specified message ID to the specified priority.int
QueueControl.changeMessagesPriority
(String filter, int newPriority) Changes the priority for all the message corresponding to the specified filter to the specified priority.void
ActiveMQServerControl.clearAuthenticationCache()
void
ActiveMQServerControl.clearAuthorizationCache()
boolean
ActiveMQServerControl.closeConnectionsForAddress
(String ipAddress) Closes all the connections of clients connected to this server which matches the specified IP address.boolean
ActiveMQServerControl.closeConnectionsForUser
(String address) Closes all the connections of sessions with a matching user name.boolean
ActiveMQServerControl.closeConnectionWithID
(String ID) Closes the connection with the given id.boolean
ActiveMQServerControl.closeConsumerConnectionsForAddress
(String address) Closes all the connections of clients connected to this server which matches the specified IP address.boolean
ActiveMQServerControl.closeConsumerWithID
(String sessionID, String ID) Closes the consumer with the given id.boolean
ActiveMQServerControl.closeSessionWithID
(String connectionID, String ID) Closes the session with the given id.boolean
ActiveMQServerControl.closeSessionWithID
(String connectionID, String ID, boolean force) Closes the session with the given id.boolean
ActiveMQServerControl.commitPreparedTransaction
(String transactionAsBase64) Heuristically commits a prepared transaction.boolean
QueueControl.copyMessage
(long messageID, String targetQueue) long
QueueControl.countDeliveringMessages
(String filter) Counts the number of delivering messages in this queue matching the specified filter.QueueControl.countDeliveringMessages
(String filter, String groupByProperty) Counts the number of delivering messages in this queue matching the specified filter, grouped by the given property field.long
QueueControl.countMessages()
long
QueueControl.countMessages
(String filter) Counts the number of messages in this queue matching the specified filter.QueueControl.countMessages
(String filter, String groupByProperty) Counts the number of messages in this queue matching the specified filter, grouped by the given property field.ActiveMQServerControl.createAddress
(String name, String routingTypes) void
ActiveMQServerControl.createBridge
(String bridgeConfiguration) Create a bridge.void
ActiveMQServerControl.createBridge
(String name, String queueName, String forwardingAddress, String filterString, String transformerClassName, long retryInterval, double retryIntervalMultiplier, int initialConnectAttempts, int reconnectAttempts, boolean useDuplicateDetection, int confirmationWindowSize, int producerWindowSize, long clientFailureCheckPeriod, String connectorNames, boolean useDiscoveryGroup, boolean ha, String user, String password) Deprecated.void
ActiveMQServerControl.createBridge
(String name, String queueName, String forwardingAddress, String filterString, String transformerClassName, long retryInterval, double retryIntervalMultiplier, int initialConnectAttempts, int reconnectAttempts, boolean useDuplicateDetection, int confirmationWindowSize, long clientFailureCheckPeriod, String connectorNames, boolean useDiscoveryGroup, boolean ha, String user, String password) Deprecated.Deprecated in favour ofActiveMQServerControl.createBridge(String)
void
ActiveMQServerControl.createBridge
(String name, String queueName, String forwardingAddress, String filterString, String transformerClassName, String transformerPropertiesAsJSON, long retryInterval, double retryIntervalMultiplier, int initialConnectAttempts, int reconnectAttempts, boolean useDuplicateDetection, int confirmationWindowSize, int producerWindowSize, long clientFailureCheckPeriod, String connectorNames, boolean useDiscoveryGroup, boolean ha, String user, String password) Deprecated.Deprecated in favour ofActiveMQServerControl.createBridge(String)
void
ActiveMQServerControl.createBridge
(String name, String queueName, String forwardingAddress, String filterString, String transformerClassName, Map<String, String> transformerProperties, long retryInterval, double retryIntervalMultiplier, int initialConnectAttempts, int reconnectAttempts, boolean useDuplicateDetection, int confirmationWindowSize, int producerWindowSize, long clientFailureCheckPeriod, String connectorNames, boolean useDiscoveryGroup, boolean ha, String user, String password) Deprecated.Deprecated in favour ofActiveMQServerControl.createBridge(String)
void
ActiveMQServerControl.createConnectorService
(String name, String factoryClass, Map<String, Object> parameters) void
ActiveMQServerControl.createDivert
(String divertConfiguration) Create a Divert.void
ActiveMQServerControl.createDivert
(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName) Deprecated.Deprecated in favor ofActiveMQServerControl.createDivert(String)
void
ActiveMQServerControl.createDivert
(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName, String routingType) Deprecated.Deprecated in favor ofActiveMQServerControl.createDivert(String)
void
ActiveMQServerControl.createDivert
(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName, String transformerPropertiesAsJSON, String routingType) Deprecated.Deprecated in favor ofActiveMQServerControl.createDivert(String)
void
ActiveMQServerControl.createDivert
(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName, Map<String, String> transformerProperties, String routingType) Deprecated.Deprecated in favor ofActiveMQServerControl.createDivert(String)
ActiveMQServerControl.createQueue
(String queueConfiguration) Create a queue.ActiveMQServerControl.createQueue
(String queueConfiguration, boolean ignoreIfExists) Create a queue.void
ActiveMQServerControl.createQueue
(String address, String name) Deprecated.void
ActiveMQServerControl.createQueue
(String address, String name, boolean durable) Deprecated.void
ActiveMQServerControl.createQueue
(String address, String name, boolean durable, String routingType) Deprecated.void
ActiveMQServerControl.createQueue
(String address, String name, String routingType) Deprecated.void
ActiveMQServerControl.createQueue
(String address, String name, String filter, boolean durable) Deprecated.void
ActiveMQServerControl.createQueue
(String address, String name, String filter, boolean durable, String routingType) Deprecated.ActiveMQServerControl.createQueue
(String address, String routingType, String name, String filterStr, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress) Deprecated.ActiveMQServerControl.createQueue
(String address, String routingType, String name, String filterStr, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, String lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoCreateAddress) Deprecated.ActiveMQServerControl.createQueue
(String address, String routingType, String name, String filterStr, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, String lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.ActiveMQServerControl.createQueue
(String address, String routingType, String name, String filterStr, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, String groupFirstKey, boolean lastValue, String lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.ActiveMQServerControl.createQueue
(String address, String routingType, String name, String filterStr, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, String groupFirstKey, boolean lastValue, String lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, long ringSize) Deprecated.void
ActiveMQServerControl.deleteAddress
(String name) void
ActiveMQServerControl.deleteAddress
(String name, boolean force) void
QueueControl.deliverScheduledMessage
(long messageId) Deliver the scheduled message with the specified message IDvoid
QueueControl.deliverScheduledMessages
(String filter) Deliver the scheduled messages which match the filtervoid
ActiveMQServerControl.deployQueue
(String address, String name, String filter) Deprecated.void
ActiveMQServerControl.deployQueue
(String address, String name, String filter, boolean durable) Deprecated.void
ActiveMQServerControl.destroyBridge
(String name) void
ActiveMQServerControl.destroyConnectorService
(String name) void
ActiveMQServerControl.destroyDivert
(String name) void
ActiveMQServerControl.destroyQueue
(String name) Destroys the queue corresponding to the specified name.void
ActiveMQServerControl.destroyQueue
(String name, boolean removeConsumers) Destroys the queue corresponding to the specified name.void
ActiveMQServerControl.destroyQueue
(String name, boolean removeConsumers, boolean autoDeleteAddress) Destroys the queue corresponding to the specified name and delete it's address if there are no other queuesvoid
QueueControl.disable()
Enables the queue.void
ActiveMQServerControl.disableMessageCounters()
Disables message counters for this server.void
QueueControl.enable()
Enables the queue.void
ActiveMQServerControl.enableMessageCounters()
Enables message counters for this server.boolean
QueueControl.expireMessage
(long messageID) Expires the message corresponding to the specified message ID.int
QueueControl.expireMessages
(String filter) Expires all the message corresponding to the specified filter.void
ActiveMQServerControl.exportConfigAsProperties()
void
QueueControl.flushExecutor()
it will flush one cycle on internal executors, so you would be sure that any pending tasks are done before you call any other measure.void
ActiveMQServerControl.forceFailover()
boolean
ActiveMQServerControl.freezeReplication()
ActiveMQServerControl.getAddressInfo
(String address) ActiveMQServerControl.getAddressSettingsAsJSON
(String addressMatch) Returns the address settings as a JSON string.ClusterConnectionControl.getBridgeMetrics
(String nodeId) The bridge metrics for the given node in the cluster connectionString[]
ActiveMQServerControl.getClusterConnectionNames()
Returns the names of the cluster-connections deployed on this server..ConnectionRouterControl.getLocalTargetFilter()
String[]
ActiveMQServerControl.getQueueNames
(String routingType) Returns the names of the queues created on this server with the given routing-type..Object[]
ActiveMQServerControl.getRolesAsJSON
(String addressMatch) ConnectionRouterControl.getTargetAsJSON
(String key) ConnectionRouterControl.getTargetKeyFilter()
ActiveMQServerControl.listAddresses
(String separator) ActiveMQServerControl.listAddresses
(String options, int page, int pageSize) ActiveMQServerControl.listAllConsumersAsJSON()
Lists all the consumers connected to this server.ActiveMQServerControl.listAllSessionsAsJSON()
Lists details about all sessions.ActiveMQServerControl.listBindingsForAddress
(String address) ActiveMQServerControl.listBrokerConnections()
String[]
ActiveMQServerControl.listConnectionIDs()
Lists all the IDs of the connections connected to this server.ActiveMQServerControl.listConnections
(String options, int page, int pageSize) ActiveMQServerControl.listConnectionsAsJSON()
Lists all the connections connected to this server.ActiveMQServerControl.listConsumers
(String options, int page, int pageSize) ActiveMQServerControl.listConsumersAsJSON
(String connectionID) Lists all the consumers which belongs to the connection specified by the connectionID.QueueControl.listConsumersAsJSON()
QueueControl.listDeliveringMessages()
Lists all the messages being deliver per consumer.QueueControl.listDeliveringMessagesAsJSON()
Executes a conversion ofQueueControl.listDeliveringMessages()
to JSONdefault String[]
ActiveMQServerControl.listDivertNames()
Jon plugin doesn't recognize an Operation whose name is in form getXXXX(), so add this one.QueueControl.listGroupsAsJSON()
String[]
ActiveMQServerControl.listHeuristicCommittedTransactions()
List transactions which have been heuristically committed.String[]
ActiveMQServerControl.listHeuristicRolledBackTransactions()
List transactions which have been heuristically rolled back.QueueControl.listMessageCounter()
Lists the message counter for this queue.QueueControl.listMessageCounterAsHTML()
Lists the message counter for this queue as a HTML table.QueueControl.listMessageCounterHistory()
Lists the message counter history for this queue.QueueControl.listMessageCounterHistoryAsHTML()
Deprecated.QueueControl.listMessages
(String filter) Lists all the messages in this queue matching the specified filter.QueueControl.listMessagesAsJSON
(String filter) Lists all the messages in this queue matching the specified filter using JSON serialization.ActiveMQServerControl.listNetworkTopology()
ActiveMQServerControl.listPreparedTransactionDetailsAsHTML()
Deprecated.ActiveMQServerControl.listPreparedTransactionDetailsAsJSON()
List all the prepared transaction, sorted by date, oldest first, with details, in text format.String[]
ActiveMQServerControl.listPreparedTransactions()
List all the prepared transaction, sorted by date, oldest first.ActiveMQServerControl.listProducers
(String options, int page, int pageSize) ActiveMQServerControl.listProducersInfoAsJSON()
ActiveMQServerControl.listQueues
(String options, int page, int pageSize) String[]
ActiveMQServerControl.listRemoteAddresses()
Lists the addresses of all the clients connected to this address.String[]
ActiveMQServerControl.listRemoteAddresses
(String ipAddress) Lists the addresses of the clients connected to this address which matches the specified IP address.QueueControl.listScheduledMessages()
Lists all the messages scheduled for delivery for this queue.QueueControl.listScheduledMessagesAsJSON()
Lists all the messages scheduled for delivery for this queue using JSON serialization.String[]
ActiveMQServerControl.listSessions
(String connectionID) Lists all the sessions IDs for the specified connection ID.ActiveMQServerControl.listSessions
(String options, int page, int pageSize) ActiveMQServerControl.listSessionsAsJSON
(String connectionID) Lists details about all the sessions for the specified connection ID.List the information about a user or all users if no username is supplied (only applicable when using the JAAS PropertiesLoginModule or the ActiveMQBasicSecurityManager).boolean
QueueControl.moveMessage
(long messageID, String otherQueueName) Moves the message corresponding to the specified message ID to the specified other queue.boolean
QueueControl.moveMessage
(long messageID, String otherQueueName, boolean rejectDuplicates) Moves the message corresponding to the specified message ID to the specified other queue.int
QueueControl.moveMessages
(int flushLimit, String filter, String otherQueueName, boolean rejectDuplicates) int
QueueControl.moveMessages
(int flushLimit, String filter, String otherQueueName, boolean rejectDuplicates, int messageCount) int
QueueControl.moveMessages
(String filter, String otherQueueName) Moves all the message corresponding to the specified filter to the specified other queue.int
QueueControl.moveMessages
(String filter, String otherQueueName, boolean rejectDuplicates) Moves all the message corresponding to the specified filter to the specified other queue.void
AddressControl.pause()
Pauses all the queues bound to this address.void
AddressControl.pause
(boolean persist) Pauses all the queues bound to this address.void
QueueControl.pause()
Pauses the queue.void
QueueControl.pause
(boolean persist) Pauses the queue.QueueControl.peekFirstMessageAsJSON()
Returns the first message on the queue as JSON.QueueControl.peekFirstScheduledMessageAsJSON()
Returns the first scheduled message on the queue as JSON.long
AddressControl.purge()
Purge all the queues bound of this address.void
AcceptorControl.reload()
Re-create the acceptor with the existing configuration values.void
ActiveMQServerControl.reloadConfigurationFile()
void
ActiveMQServerControl.removeAddressSettings
(String addressMatch) int
QueueControl.removeAllMessages()
Removes all the message from the queue.void
ActiveMQServerControl.removeConnector
(String name) boolean
QueueControl.removeMessage
(long messageID) Removes the message corresponding to the specified message ID.int
QueueControl.removeMessages
(int flushLimit, String filter) Removes all the message corresponding to the specified filter.int
QueueControl.removeMessages
(String filter) Removes all the message corresponding to the specified filter.void
ActiveMQServerControl.removeSecuritySettings
(String addressMatch) void
ActiveMQServerControl.removeUser
(String username) Remove a user (only applicable when using the JAAS PropertiesLoginModule or the ActiveMQBasicSecurityManager).void
Replays messages from all files in the retention folder that match an address and filter.void
ActiveMQServerControl.replay
(String startScan, String endScan, String address, String target, String filter) Replays messages from a configurable subset of the files in the retention folder that match an address and filter.void
void
void
QueueControl.resetAllGroups()
Will reset the all the groups.void
ActiveMQServerControl.resetAllMessageCounterHistories()
Reset histories for all message counters.void
ActiveMQServerControl.resetAllMessageCounters()
Reset all message counters.void
QueueControl.resetGroup
(String groupID) Will reset the group matching the given groupID.void
QueueControl.resetMessageCounter()
Resets the message counter for this queue.void
QueueControl.resetMessagesAcknowledged()
Resets the MessagesAdded propertyvoid
QueueControl.resetMessagesAdded()
Resets the MessagesAdded propertyvoid
QueueControl.resetMessagesExpired()
Resets the MessagesExpired propertyvoid
QueueControl.resetMessagesKilled()
Resets the MessagesExpired propertyvoid
Set new properties on an existing user (only applicable when using the JAAS PropertiesLoginModule or the ActiveMQBasicSecurityManager).void
Set new properties on an existing user (only applicable when using the JAAS PropertiesLoginModule or the ActiveMQBasicSecurityManager).void
ActiveMQServerControl.restartEmbeddedWebServer()
void
ActiveMQServerControl.restartEmbeddedWebServer
(long timeout) void
AddressControl.resume()
Resume all the queues bound of this address.void
QueueControl.resume()
Resumes the queue.boolean
QueueControl.retryMessage
(long messageID) Retries the message corresponding to the given messageID to the original queue.int
QueueControl.retryMessages()
Retries all messages on a DLQ to their respective original queues.boolean
ActiveMQServerControl.rollbackPreparedTransaction
(String transactionAsBase64) Heuristically rolls back a prepared transaction.void
void
AddressControl.schedulePageCleanup()
AddressControl.sendMessage
(Map<String, String> headers, int type, String body, boolean durable, String user, String password) Sends a TextMessage to a password-protected address.AddressControl.sendMessage
(Map<String, String> headers, int type, String body, boolean durable, String user, String password, boolean createMessageId) Sends a TextMessage to a password-protected address.QueueControl.sendMessage
(Map<String, String> headers, int type, String body, boolean durable, String user, String password) Sends a TextMessage to a password-protected destination.QueueControl.sendMessage
(Map<String, String> headers, int type, String body, boolean durable, String user, String password, boolean createMessageId) Sends a TextMessage to a password-protected destination.int
QueueControl.sendMessagesToDeadLetterAddress
(String filterStr) Sends all the message corresponding to the specified filter to this queue's dead letter address.boolean
QueueControl.sendMessageToDeadLetterAddress
(long messageID) Sends the message corresponding to the specified message ID to this queue's dead letter address.void
ConnectionRouterControl.setLocalTargetFilter
(String regExp) void
ConnectionRouterControl.setTargetKeyFilter
(String regExp) void
ActiveMQComponentControl.start()
Starts this component.void
ActiveMQServerControl.startBrokerConnection
(String name) void
ActiveMQServerControl.startEmbeddedWebServer()
void
ActiveMQComponentControl.stop()
Stops this component.void
ActiveMQServerControl.stopBrokerConnection
(String name) void
ActiveMQServerControl.stopEmbeddedWebServer()
void
AddressControl.unblock()
ActiveMQServerControl.updateAddress
(String name, String routingTypes) void
ActiveMQServerControl.updateDivert
(String divertConfiguration) update a divertvoid
ActiveMQServerControl.updateDivert
(String name, String forwardingAddress, String filterString, String transformerClassName, Map<String, String> transformerProperties, String routingType) Deprecated.ActiveMQServerControl.updateQueue
(String queueConfiguration) Update a queue.ActiveMQServerControl.updateQueue
(String name, String routingType, Integer maxConsumers, Boolean purgeOnNoConsumers) Deprecated.ActiveMQServerControl.updateQueue
(String name, String routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive) Deprecated.ActiveMQServerControl.updateQueue
(String name, String routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, String user) Deprecated.ActiveMQServerControl.updateQueue
(String name, String routingType, String filter, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user) Deprecated.ActiveMQServerControl.updateQueue
(String name, String routingType, String filter, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, String groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user) Deprecated.ActiveMQServerControl.updateQueue
(String name, String routingType, String filter, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, String groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user, Long ringSize) Deprecated.
ActiveMQServerControl.createBridge(String)