Package | Description |
---|---|
org.apache.activemq.artemis.api.core.management |
Modifier and Type | Method and Description |
---|---|
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)
adds a new address setting for a specific address
|
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)
adds a new address setting for a specific address
|
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) |
CompositeData[] |
QueueControl.browse() |
CompositeData[] |
QueueControl.browse(String filter)
Resets the MessagesAdded property
|
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.
|
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.closeConsumerConnectionsForAddress(String address)
Closes all the connections of clients connected to this server which matches the specified IP address.
|
boolean |
ActiveMQServerControl.commitPreparedTransaction(String transactionAsBase64)
Heuristically commits a prepared transaction.
|
long |
QueueControl.countMessages(String filter)
Counts the number of messages in this queue matching the specified filter.
|
String |
ActiveMQServerControl.createAddress(String name,
String routingTypes) |
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) |
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) |
void |
ActiveMQServerControl.createConnectorService(String name,
String factoryClass,
Map<String,Object> parameters) |
void |
ActiveMQServerControl.createDivert(String name,
String routingName,
String address,
String forwardingAddress,
boolean exclusive,
String filterString,
String transformerClassName) |
void |
ActiveMQServerControl.createDivert(String name,
String routingName,
String address,
String forwardingAddress,
boolean exclusive,
String filterString,
String transformerClassName,
String routingType) |
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)
Create a queue.
|
void |
ActiveMQServerControl.createQueue(String address,
String name,
String routingType)
Create a durable queue.
|
void |
ActiveMQServerControl.createQueue(String address,
String name,
String filter,
boolean durable)
Create a queue.
|
void |
ActiveMQServerControl.createQueue(String address,
String name,
String filter,
boolean durable,
String routingType)
Create a queue.
|
void |
ActiveMQServerControl.deleteAddress(String name) |
void |
ActiveMQServerControl.deployQueue(String address,
String name,
String filter)
Deploy a durable queue.
|
void |
ActiveMQServerControl.deployQueue(String address,
String name,
String filter,
boolean durable)
Deploy a queue.
|
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 queues
|
void |
ActiveMQServerControl.disableMessageCounters()
Disables message counters for this server.
|
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.forceFailover() |
String |
ActiveMQServerControl.getAddressInfo(String address) |
String |
ActiveMQServerControl.getAddressSettingsAsJSON(String addressMatch)
returns the address settings as a JSON string
|
Object[] |
ActiveMQServerControl.getRoles(String addressMatch) |
String |
ActiveMQServerControl.getRolesAsJSON(String addressMatch) |
String |
ActiveMQServerControl.listAddresses(String separator) |
String |
ActiveMQServerControl.listAllConsumersAsJSON()
Lists all the consumers connected to this server.
|
String |
ActiveMQServerControl.listBindingsForAddress(String address) |
String[] |
ActiveMQServerControl.listConnectionIDs()
Lists all the IDs of the connections connected to this server.
|
String |
ActiveMQServerControl.listConnectionsAsJSON()
Lists all the connections connected to this server.
|
String |
QueueControl.listConsumersAsJSON() |
String |
ActiveMQServerControl.listConsumersAsJSON(String connectionID)
Lists all the consumers which belongs to the connection specified by the connectionID.
|
Map<String,Map<String,Object>[]> |
QueueControl.listDeliveringMessages()
Lists all the messages being deliver per consumer.
|
String |
QueueControl.listDeliveringMessagesAsJSON()
Executes a conversion of
QueueControl.listDeliveringMessages() to JSON |
String[] |
ActiveMQServerControl.listHeuristicCommittedTransactions()
List transactions which have been heuristically committed.
|
String[] |
ActiveMQServerControl.listHeuristicRolledBackTransactions()
List transactions which have been heuristically rolled back.
|
String |
QueueControl.listMessageCounter()
Lists the message counter for this queue.
|
String |
QueueControl.listMessageCounterAsHTML()
Lists the message counter for this queue as a HTML table.
|
String |
QueueControl.listMessageCounterHistory()
Lists the message counter history for this queue.
|
String |
QueueControl.listMessageCounterHistoryAsHTML()
Lists the message counter history for this queue as a HTML table.
|
Map<String,Object>[] |
QueueControl.listMessages(String filter)
Lists all the messages in this queue matching the specified filter.
|
String |
QueueControl.listMessagesAsJSON(String filter)
Lists all the messages in this queue matching the specified filter using JSON serialization.
|
String |
ActiveMQServerControl.listNetworkTopology() |
String |
ActiveMQServerControl.listPreparedTransactionDetailsAsHTML()
List all the prepared transaction, sorted by date,
oldest first, with details, in HTML format
|
String |
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.
|
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.
|
Map<String,Object>[] |
QueueControl.listScheduledMessages()
Lists all the messages scheduled for delivery for this queue.
|
String |
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.
|
String |
ActiveMQServerControl.listSessionsAsJSON(String connectionID)
Lists details about all the sessions for the specified connection ID.
|
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(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 |
QueueControl.pause()
Pauses the queue.
|
void |
QueueControl.pause(boolean persist)
Pauses the queue.
|
void |
AcceptorControl.reload()
Re-create the acceptor with the existing configuration values.
|
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.resetAllMessageCounterHistories()
Reset histories for all message counters.
|
void |
ActiveMQServerControl.resetAllMessageCounters()
Reset all message counters.
|
void |
QueueControl.resetMessageCounter()
Resets the message counter for this queue.
|
void |
QueueControl.resetMessagesAcknowledged()
Resets the MessagesAdded property
|
void |
QueueControl.resetMessagesAdded()
Resets the MessagesAdded property
|
void |
QueueControl.resetMessagesExpired()
Resets the MessagesExpired property
|
void |
QueueControl.resetMessagesKilled()
Resets the MessagesExpired property
|
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 |
ActiveMQServerControl.scaleDown(String connector) |
String |
AddressControl.sendMessage(Map<String,String> headers,
int type,
String body,
boolean durable,
String user,
String password) |
String |
QueueControl.sendMessage(Map<String,String> headers,
int type,
String body,
boolean durable,
String user,
String password) |
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 |
ActiveMQComponentControl.start()
Starts this component.
|
void |
ActiveMQComponentControl.stop()
Stops this component.
|
String |
ActiveMQServerControl.updateAddress(String name,
String routingTypes) |
Copyright © 2017 The Apache Software Foundation. All Rights Reserved.