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 addressSettingsAsJson) Adds address-settings for matching addresses.voidActiveMQServerControl.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, for removal: This API element is subject to removal in a future version.voidActiveMQServerControl.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, for removal: This API element is subject to removal in a future version.voidActiveMQServerControl.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, for removal: This API element is subject to removal in a future version.voidActiveMQServerControl.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, for removal: This API element is subject to removal in a future version.voidActiveMQServerControl.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, for removal: This API element is subject to removal in a future version.voidActiveMQServerControl.addConnector(String name, String url) voidActiveMQServerControl.addSecuritySettings(String addressMatch, String securitySettingsAsJson) Add security-settings for matching addresses.voidActiveMQServerControl.addSecuritySettings(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles) Deprecated, for removal: This API element is subject to removal in a future version.voidActiveMQServerControl.addSecuritySettings(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles, String browseRoles) Deprecated, for removal: This API element is subject to removal in a future version.voidActiveMQServerControl.addSecuritySettings(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles, String browseRoles, String createAddressRoles, String deleteAddressRoles) Deprecated, for removal: This API element is subject to removal in a future version.voidActiveMQServerControl.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) Deprecated, for removal: This API element is subject to removal in a future version.voidAdd a user (only applicable when using the JAAS PropertiesLoginModule or the ActiveMQBasicSecurityManager)booleanAddressControl.block()Blocks message production to this address by limiting creditQueueControl.browse()QueueControl.browse(int page, int pageSize) booleanQueueControl.changeMessagePriority(long messageID, int newPriority) Changes the message's priority corresponding to the specified message ID to the specified priority.intQueueControl.changeMessagesPriority(String filter, int newPriority) Changes the priority for all the message corresponding to the specified filter to the specified priority.voidActiveMQServerControl.clearAuthenticationCache()voidActiveMQServerControl.clearAuthorizationCache()booleanActiveMQServerControl.closeConnectionsForAddress(String ipAddress) Closes all the connections of clients connected to this server which matches the specified IP address.booleanActiveMQServerControl.closeConnectionsForUser(String address) Closes all the connections of sessions with a matching user name.booleanActiveMQServerControl.closeConnectionWithID(String ID) Closes the connection with the given id.booleanActiveMQServerControl.closeConsumerConnectionsForAddress(String address) Closes all the connections of clients connected to this server which matches the specified IP address.booleanActiveMQServerControl.closeConsumerWithID(String sessionID, String ID) Closes the consumer with the given id.booleanActiveMQServerControl.closeSessionWithID(String connectionID, String ID) Closes the session with the given id.booleanActiveMQServerControl.closeSessionWithID(String connectionID, String ID, boolean force) Closes the session with the given id.booleanActiveMQServerControl.commitPreparedTransaction(String transactionAsBase64) Heuristically commits a prepared transaction.booleanQueueControl.copyMessage(long messageID, String targetQueue) longQueueControl.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.longQueueControl.countMessages()longQueueControl.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) voidActiveMQServerControl.createBridge(String bridgeConfiguration) Create a bridge.voidActiveMQServerControl.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, for removal: This API element is subject to removal in a future version.Deprecated in favour ofActiveMQServerControl.createBridge(String)voidActiveMQServerControl.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, for removal: This API element is subject to removal in a future version.Deprecated in favour ofActiveMQServerControl.createBridge(String)voidActiveMQServerControl.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, for removal: This API element is subject to removal in a future version.Deprecated in favour ofActiveMQServerControl.createBridge(String)voidActiveMQServerControl.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, for removal: This API element is subject to removal in a future version.Deprecated in favour ofActiveMQServerControl.createBridge(String)voidActiveMQServerControl.createConnectorService(String name, String factoryClass, Map<String, Object> parameters) voidActiveMQServerControl.createDivert(String divertConfiguration) Adds a divert.voidActiveMQServerControl.createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName) Deprecated, for removal: This API element is subject to removal in a future version.Deprecated in favor ofActiveMQServerControl.createDivert(String)voidActiveMQServerControl.createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName, String routingType) Deprecated, for removal: This API element is subject to removal in a future version.Deprecated in favor ofActiveMQServerControl.createDivert(String)voidActiveMQServerControl.createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName, String transformerPropertiesAsJSON, String routingType) Deprecated, for removal: This API element is subject to removal in a future version.Deprecated in favor ofActiveMQServerControl.createDivert(String)voidActiveMQServerControl.createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName, Map<String, String> transformerProperties, String routingType) Deprecated, for removal: This API element is subject to removal in a future version.Deprecated in favor ofActiveMQServerControl.createDivert(String)ActiveMQServerControl.createQueue(String queueConfiguration) Create a queue.ActiveMQServerControl.createQueue(String queueConfiguration, boolean ignoreIfExists) Create a queue.voidActiveMQServerControl.createQueue(String address, String name) Deprecated, for removal: This API element is subject to removal in a future version.UseActiveMQServerControl.createQueue(String)instead.voidActiveMQServerControl.createQueue(String address, String name, boolean durable) Deprecated, for removal: This API element is subject to removal in a future version.UseActiveMQServerControl.createQueue(String)instead.voidActiveMQServerControl.createQueue(String address, String name, boolean durable, String routingType) Deprecated, for removal: This API element is subject to removal in a future version.UseActiveMQServerControl.createQueue(String)instead.voidActiveMQServerControl.createQueue(String address, String name, String routingType) Deprecated, for removal: This API element is subject to removal in a future version.UseActiveMQServerControl.createQueue(String)instead.voidActiveMQServerControl.createQueue(String address, String name, String filter, boolean durable) Deprecated, for removal: This API element is subject to removal in a future version.UseActiveMQServerControl.createQueue(String)instead.voidActiveMQServerControl.createQueue(String address, String name, String filter, boolean durable, String routingType) Deprecated, for removal: This API element is subject to removal in a future version.UseActiveMQServerControl.createQueue(String)instead.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, for removal: This API element is subject to removal in a future version.UseActiveMQServerControl.createQueue(String)instead.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.voidActiveMQServerControl.deleteAddress(String name) voidActiveMQServerControl.deleteAddress(String name, boolean force) voidQueueControl.deliverScheduledMessage(long messageId) Deliver the scheduled message with the specified message IDvoidQueueControl.deliverScheduledMessages(String filter) Deliver the scheduled messages which match the filtervoidActiveMQServerControl.deployQueue(String address, String name, String filter) Deprecated.voidActiveMQServerControl.deployQueue(String address, String name, String filter, boolean durable) Deprecated.voidActiveMQServerControl.destroyBridge(String name) voidActiveMQServerControl.destroyConnectorService(String name) voidActiveMQServerControl.destroyDivert(String name) voidActiveMQServerControl.destroyQueue(String name) Destroys the queue corresponding to the specified name.voidActiveMQServerControl.destroyQueue(String name, boolean removeConsumers) Destroys the queue corresponding to the specified name.voidActiveMQServerControl.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 queuesvoidQueueControl.disable()Enables the queue.voidActiveMQServerControl.disableMessageCounters()Disables message counters for this server.voidQueueControl.enable()Enables the queue.voidActiveMQServerControl.enableMessageCounters()Enables message counters for this server.booleanQueueControl.expireMessage(long messageID) Expires the message corresponding to the specified message ID.intQueueControl.expireMessages(String filter) Expires all the message corresponding to the specified filter.voidActiveMQServerControl.exportConfigAsProperties()voidQueueControl.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.voidActiveMQServerControl.forceFailover()booleanActiveMQServerControl.freezeReplication()ActiveMQServerControl.getAddressInfo(String address) ActiveMQServerControl.getAddressSettingsAsJSON(String addressMatch) Get address-settings for matching address, e.g.: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) Retrieves roles associated with a specific address match as JSON.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 to this server as JSON.ActiveMQServerControl.listConsumers(String options, int page, int pageSize) ActiveMQServerControl.listConsumersAsJSON(String connectionID) Lists all the consumers that belong 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, for removal: This API element is subject to removal in a future version.ActiveMQServerControl.listPreparedTransactionDetailsAsJSON()List all the prepared transaction as JSON.String[]ActiveMQServerControl.listPreparedTransactions()List all the prepared transaction, sorted by date, oldest first.ActiveMQServerControl.listProducers(String options, int page, int pageSize) ActiveMQServerControl.listProducersInfoAsJSON()List details as JSON about the producers sending messages to this broker.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).booleanQueueControl.moveMessage(long messageID, String otherQueueName) Moves the message corresponding to the specified message ID to the specified other queue.booleanQueueControl.moveMessage(long messageID, String otherQueueName, boolean rejectDuplicates) Moves the message corresponding to the specified message ID to the specified other queue.intQueueControl.moveMessages(int flushLimit, String filter, String otherQueueName, boolean rejectDuplicates) intQueueControl.moveMessages(int flushLimit, String filter, String otherQueueName, boolean rejectDuplicates, int messageCount) intQueueControl.moveMessages(String filter, String otherQueueName) Moves all the message corresponding to the specified filter to the specified other queue.intQueueControl.moveMessages(String filter, String otherQueueName, boolean rejectDuplicates) Moves all the message corresponding to the specified filter to the specified other queue.voidAddressControl.pause()Pauses all the queues bound to this address.voidAddressControl.pause(boolean persist) Pauses all the queues bound to this address.voidQueueControl.pause()Pauses the queue.voidQueueControl.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.longAddressControl.purge()Purge all the queues bound of this address.voidAcceptorControl.reload()Re-create the acceptor with the existing configuration values.voidActiveMQServerControl.reloadConfigurationFile()voidActiveMQServerControl.removeAddressSettings(String addressMatch) intQueueControl.removeAllMessages()Removes all the message from the queue.voidActiveMQServerControl.removeConnector(String name) booleanQueueControl.removeMessage(long messageID) Removes the message corresponding to the specified message ID.intQueueControl.removeMessages(int flushLimit, String filter) Removes all the message corresponding to the specified filter.intQueueControl.removeMessages(String filter) Removes all the message corresponding to the specified filter.voidActiveMQServerControl.removeSecuritySettings(String addressMatch) voidActiveMQServerControl.removeUser(String username) Remove a user (only applicable when using the JAAS PropertiesLoginModule or the ActiveMQBasicSecurityManager).voidReplays messages from all files in the retention folder that match an address and filter.voidActiveMQServerControl.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.voidvoidvoidQueueControl.resetAllGroups()Will reset the all the groups.voidActiveMQServerControl.resetAllMessageCounterHistories()Reset histories for all message counters.voidActiveMQServerControl.resetAllMessageCounters()Reset all message counters.voidQueueControl.resetGroup(String groupID) Will reset the group matching the given groupID.voidQueueControl.resetMessageCounter()Resets the message counter for this queue.voidQueueControl.resetMessagesAcknowledged()Resets the MessagesAdded propertyvoidQueueControl.resetMessagesAdded()Resets the MessagesAdded propertyvoidQueueControl.resetMessagesExpired()Resets the MessagesExpired propertyvoidQueueControl.resetMessagesKilled()Resets the MessagesExpired propertyvoidSet new properties on an existing user (only applicable when using the JAAS PropertiesLoginModule or the ActiveMQBasicSecurityManager).voidSet new properties on an existing user (only applicable when using the JAAS PropertiesLoginModule or the ActiveMQBasicSecurityManager).voidActiveMQServerControl.restartEmbeddedWebServer()voidActiveMQServerControl.restartEmbeddedWebServer(long timeout) voidAddressControl.resume()Resume all the queues bound of this address.voidQueueControl.resume()Resumes the queue.booleanQueueControl.retryMessage(long messageID) Retries the message corresponding to the given messageID to the original queue.intQueueControl.retryMessages()Retries all messages on a DLQ to their respective original queues.intQueueControl.retryMessages(String filter) Retries all messages that match the given filter on a DLQ to their respective original queues.booleanActiveMQServerControl.rollbackPreparedTransaction(String transactionAsBase64) Heuristically rolls back a prepared transaction.voidvoidAddressControl.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.intQueueControl.sendMessagesToDeadLetterAddress(String filterStr) Sends all the message corresponding to the specified filter to this queue's dead letter address.booleanQueueControl.sendMessageToDeadLetterAddress(long messageID) Sends the message corresponding to the specified message ID to this queue's dead letter address.voidConnectionRouterControl.setLocalTargetFilter(String regExp) voidConnectionRouterControl.setTargetKeyFilter(String regExp) voidActiveMQComponentControl.start()Starts this component.voidActiveMQServerControl.startBrokerConnection(String name) voidActiveMQServerControl.startEmbeddedWebServer()voidActiveMQComponentControl.stop()Stops this component.voidActiveMQServerControl.stopBrokerConnection(String name) voidActiveMQServerControl.stopEmbeddedWebServer()voidAddressControl.unblock()ActiveMQServerControl.updateAddress(String name, String routingTypes) voidActiveMQServerControl.updateDivert(String divertConfiguration) Updates a divert.voidActiveMQServerControl.updateDivert(String name, String forwardingAddress, String filterString, String transformerClassName, Map<String, String> transformerProperties, String routingType) Deprecated, for removal: This API element is subject to removal in a future version.UseActiveMQServerControl.createDivert(String)instead.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.addAddressSettings(String, String)instead.