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(int page,
int pageSize) |
CompositeData[] |
QueueControl.browse(String filter) |
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.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.commitPreparedTransaction(String transactionAsBase64)
Heuristically commits a prepared transaction.
|
long |
QueueControl.countMessages() |
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.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) |
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) |
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,
Map<String,String> transformerProperties,
String routingType) |
void |
ActiveMQServerControl.createDivert(String name,
String routingName,
String address,
String forwardingAddress,
boolean exclusive,
String filterString,
String transformerClassName,
String routingType) |
void |
ActiveMQServerControl.createDivert(String name,
String routingName,
String address,
String forwardingAddress,
boolean exclusive,
String filterString,
String transformerClassName,
String transformerPropertiesAsJSON,
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.
|
String |
ActiveMQServerControl.createQueue(String address,
String routingType,
String name,
String filterStr,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreateAddress)
Create a queue.
|
void |
ActiveMQServerControl.deleteAddress(String name) |
void |
ActiveMQServerControl.deleteAddress(String name,
boolean force) |
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 |
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() |
String |
ActiveMQServerControl.getAddressInfo(String address) |
String |
ActiveMQServerControl.getAddressSettingsAsJSON(String addressMatch)
returns the address settings as a JSON string
|
String[] |
ActiveMQServerControl.getQueueNames(String routingType)
Returns the names of the queues created on this server with the given routing-type.
|
Object[] |
ActiveMQServerControl.getRoles(String addressMatch) |
String |
ActiveMQServerControl.getRolesAsJSON(String addressMatch) |
String |
ActiveMQServerControl.listAddresses(String separator) |
String |
ActiveMQServerControl.listAddresses(String options,
int page,
int pageSize) |
String |
ActiveMQServerControl.listAllConsumersAsJSON()
Lists all the consumers connected to this server.
|
String |
ActiveMQServerControl.listAllSessionsAsJSON()
Lists details about all sessions.
|
String |
ActiveMQServerControl.listBindingsForAddress(String address) |
String[] |
ActiveMQServerControl.listConnectionIDs()
Lists all the IDs of the connections connected to this server.
|
String |
ActiveMQServerControl.listConnections(String options,
int page,
int pageSize) |
String |
ActiveMQServerControl.listConnectionsAsJSON()
Lists all the connections connected to this server.
|
String |
ActiveMQServerControl.listConsumers(String options,
int page,
int pageSize) |
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 |
default String[] |
ActiveMQServerControl.listDivertNames()
Jon plugin doesn't recognize an Operation whose name is in
form getXXXX(), so add this one.
|
String |
QueueControl.listGroupsAsJSON() |
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.listProducers(String options,
int page,
int pageSize) |
String |
ActiveMQServerControl.listProducersInfoAsJSON() |
String |
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.
|
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.listSessions(String options,
int page,
int pageSize) |
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.
|
void |
ActiveMQServerControl.removeAddressSettings(String addressMatch) |
int |
QueueControl.removeAllMessages()
Removes all the message from the queue.
|
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 |
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 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 |
QueueControl.sendMessage(Map<String,String> headers,
int type,
String body,
boolean durable,
String user,
String password) |
String |
AddressControl.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) |
String |
ActiveMQServerControl.updateQueue(String name,
String routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers)
Update a queue.
|
String |
ActiveMQServerControl.updateQueue(String name,
String routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive)
Update a queue.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.