public interface ActiveMQServerControl
Modifier and Type | Field and Description |
---|---|
static String |
ADDRESS_MEMORY_USAGE_DESCRIPTION |
static String |
ADDRESS_MEMORY_USAGE_PERCENTAGE_DESCRIPTION |
static String |
CONNECTION_COUNT_DESCRIPTION |
static String |
DISK_STORE_USAGE_DESCRIPTION |
static String |
TOTAL_CONNECTION_COUNT_DESCRIPTION |
Modifier and Type | Method and Description |
---|---|
void |
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 |
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 |
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)
adds a new address setting for a specific address
|
void |
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)
adds a new address setting for a specific address
|
void |
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)
adds a new address setting for a specific address
|
void |
addSecuritySettings(String addressMatch,
String sendRoles,
String consumeRoles,
String createDurableQueueRoles,
String deleteDurableQueueRoles,
String createNonDurableQueueRoles,
String deleteNonDurableQueueRoles,
String manageRoles) |
void |
addSecuritySettings(String addressMatch,
String sendRoles,
String consumeRoles,
String createDurableQueueRoles,
String deleteDurableQueueRoles,
String createNonDurableQueueRoles,
String deleteNonDurableQueueRoles,
String manageRoles,
String browseRoles) |
void |
addSecuritySettings(String addressMatch,
String sendRoles,
String consumeRoles,
String createDurableQueueRoles,
String deleteDurableQueueRoles,
String createNonDurableQueueRoles,
String deleteNonDurableQueueRoles,
String manageRoles,
String browseRoles,
String createAddressRoles,
String deleteAddressRoles) |
void |
addUser(String username,
String password,
String roles,
boolean plaintext)
Add a user (only applicable when using the JAAS PropertiesLoginModule)
|
boolean |
closeConnectionsForAddress(String ipAddress)
Closes all the connections of clients connected to this server which matches the specified IP address.
|
boolean |
closeConnectionsForUser(String address)
Closes all the connections of sessions with a matching user name.
|
boolean |
closeConnectionWithID(String ID)
Closes the connection with the given id.
|
boolean |
closeConsumerConnectionsForAddress(String address)
Closes all the connections of clients connected to this server which matches the specified IP address.
|
boolean |
closeConsumerWithID(String sessionID,
String ID)
Closes the consumer with the given id.
|
boolean |
closeSessionWithID(String connectionID,
String ID)
Closes the session with the given id.
|
boolean |
commitPreparedTransaction(String transactionAsBase64)
Heuristically commits a prepared transaction.
|
String |
createAddress(String name,
String routingTypes) |
void |
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 |
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 |
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 |
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 |
createConnectorService(String name,
String factoryClass,
Map<String,Object> parameters) |
void |
createDivert(String name,
String routingName,
String address,
String forwardingAddress,
boolean exclusive,
String filterString,
String transformerClassName) |
void |
createDivert(String name,
String routingName,
String address,
String forwardingAddress,
boolean exclusive,
String filterString,
String transformerClassName,
Map<String,String> transformerProperties,
String routingType) |
void |
createDivert(String name,
String routingName,
String address,
String forwardingAddress,
boolean exclusive,
String filterString,
String transformerClassName,
String routingType) |
void |
createDivert(String name,
String routingName,
String address,
String forwardingAddress,
boolean exclusive,
String filterString,
String transformerClassName,
String transformerPropertiesAsJSON,
String routingType) |
String |
createQueue(String queueConfiguration)
Create a queue.
|
String |
createQueue(String queueConfiguration,
boolean ignoreIfExists)
Create a queue.
|
void |
createQueue(String address,
String name)
Deprecated.
|
void |
createQueue(String address,
String name,
boolean durable)
Deprecated.
|
void |
createQueue(String address,
String name,
boolean durable,
String routingType)
Deprecated.
|
void |
createQueue(String address,
String name,
String routingType)
Deprecated.
|
void |
createQueue(String address,
String name,
String filter,
boolean durable)
Deprecated.
|
void |
createQueue(String address,
String name,
String filter,
boolean durable,
String routingType)
Deprecated.
|
String |
createQueue(String address,
String routingType,
String name,
String filterStr,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreateAddress)
Deprecated.
|
String |
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.
|
String |
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.
|
String |
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.
|
String |
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 |
deleteAddress(String name) |
void |
deleteAddress(String name,
boolean force) |
void |
deployQueue(String address,
String name,
String filter)
Deprecated.
|
void |
deployQueue(String address,
String name,
String filter,
boolean durable)
Deprecated.
|
void |
destroyBridge(String name) |
void |
destroyConnectorService(String name) |
void |
destroyDivert(String name) |
void |
destroyQueue(String name)
Destroys the queue corresponding to the specified name.
|
void |
destroyQueue(String name,
boolean removeConsumers)
Destroys the queue corresponding to the specified name.
|
void |
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 |
disableMessageCounters()
Disables message counters for this server.
|
void |
enableMessageCounters()
Enables message counters for this server.
|
void |
forceFailover() |
boolean |
freezeReplication() |
String |
getAddressInfo(String address) |
long |
getAddressMemoryUsage()
Returns the memory used by all the addresses on broker for in-memory messages
|
int |
getAddressMemoryUsagePercentage()
Returns the memory used by all the addresses on broker as a percentage of the global-max-size
|
String[] |
getAddressNames()
Returns the addresses created on this server.
|
String |
getAddressSettingsAsJSON(String addressMatch)
returns the address settings as a JSON string
|
long |
getAuthenticationCacheSize()
Returns the runtime size of the authentication cache
|
long |
getAuthorizationCacheSize()
Returns the runtime size of the authorization cache
|
String |
getBindingsDirectory()
Returns the file system directory used to store bindings.
|
String[] |
getBridgeNames() |
String[] |
getClusterConnectionNames()
Returns the names of the cluster-connections deployed on this server.
|
int |
getConnectionCount()
Returns the number of clients connected to this server.
|
long |
getConnectionTTLOverride()
Returns the connection time to live.
|
Object[] |
getConnectors()
Returns the connectors configured for this server.
|
String |
getConnectorsAsJSON()
Returns the connectors configured for this server using JSON serialization.
|
String[] |
getConnectorServices() |
int |
getDiskScanPeriod()
Returns how often the server checks for disk space usage.
|
double |
getDiskStoreUsage()
Returns the percentage of total disk store use
|
String[] |
getDivertNames() |
long |
getGlobalMaxSize()
Returns the global max bytes limit for in-memory messages.
|
String |
getHAPolicy() |
int |
getIDCacheSize()
Returns the size of the cache for pre-creating message IDs.
|
String[] |
getIncomingInterceptorClassNames()
Returns the list of interceptors used by this server for incoming messages.
|
int |
getJournalBufferSize()
Returns the size of the internal buffer on the journal.
|
int |
getJournalBufferTimeout()
Returns the timeout (in nanoseconds) used to flush internal buffers on the journal.
|
int |
getJournalCompactMinFiles()
Returns the minimal number of journal files before compacting.
|
int |
getJournalCompactPercentage()
Return the percentage of live data before compacting the journal.
|
String |
getJournalDirectory()
Returns the file system directory used to store journal log.
|
int |
getJournalFileSize()
Returns the size (in bytes) of each journal files.
|
int |
getJournalMaxIO()
Returns the maximum number of write requests that can be in the AIO queue at any given time.
|
int |
getJournalMinFiles()
Returns the number of journal files to pre-create.
|
int |
getJournalPoolFiles()
Number of files that would be acceptable to keep on a pool
|
String |
getJournalType()
Returns the type of journal used by this server (either
NIO or ASYNCIO ). |
String |
getLargeMessagesDirectory()
Returns the file system directory used to store large messages.
|
String |
getManagementAddress()
Returns the management address of this server.
|
String |
getManagementNotificationAddress()
Returns the management notification address of this server.
|
int |
getMaxDiskUsage()
Returns the disk use max limit.
|
int |
getMessageCounterMaxDayCount()
Returns the maximum number of days kept in memory for message counter.
|
long |
getMessageCounterSamplePeriod()
Returns the sample period (in milliseconds) to take message counter snapshot.
|
long |
getMessageExpiryScanPeriod()
Returns the frequency (in milliseconds) to scan messages to detect which messages
have expired.
|
long |
getMessageExpiryThreadPriority()
Deprecated.
|
String |
getNodeID()
Returns the node ID of this server.
|
String[] |
getOutgoingInterceptorClassNames()
Returns the list of interceptors used by this server for outgoing messages.
|
String |
getPagingDirectory()
Returns the file system directory used to store paging files.
|
String[] |
getQueueNames()
Returns the names of the queues created on this server.
|
String[] |
getQueueNames(String routingType)
Returns the names of the queues created on this server with the given routing-type.
|
Object[] |
getRoles(String addressMatch) |
String |
getRolesAsJSON(String addressMatch) |
int |
getScheduledThreadPoolMaxSize()
Returns the maximum number of threads in the scheduled thread pool.
|
long |
getSecurityInvalidationInterval()
Returns the interval time (in milliseconds) to invalidate security credentials.
|
int |
getThreadPoolMaxSize()
Returns the maximum number of threads in the thread pool.
|
long |
getTotalConnectionCount()
Returns the number of clients which have connected to this server since it was started.
|
long |
getTotalConsumerCount()
Returns the number of messages sent to this server since it was started.
|
long |
getTotalMessageCount()
Returns the number of messages in all queues on the server.
|
long |
getTotalMessagesAcknowledged()
Returns the number of messages sent to this server since it was started.
|
long |
getTotalMessagesAdded()
Returns the number of messages sent to this server since it was started.
|
long |
getTransactionTimeout()
Returns the timeout (in milliseconds) after which transactions is removed
from the resource manager after it was created.
|
long |
getTransactionTimeoutScanPeriod()
Returns the frequency (in milliseconds) to scan transactions to detect which transactions
have timed out.
|
String |
getUptime()
Returns the uptime of this server.
|
long |
getUptimeMillis()
Returns the uptime of this server.
|
String |
getVersion()
Returns this server's version.
|
boolean |
isActive() |
boolean |
isAsyncConnectionExecutionEnabled()
Returns whether code coming from connection is executed asynchronously or not.
|
boolean |
isBackup()
Returns
true if this server is a backup, false if it is a live server. |
boolean |
isClustered()
Returns whether this server is clustered.
|
boolean |
isCreateBindingsDir()
Returns whether the bindings directory is created on this server startup.
|
boolean |
isCreateJournalDir()
Returns whether the journal directory is created on this server startup.
|
boolean |
isFailoverOnServerShutdown()
returns if clients failover on a server shutdown
|
boolean |
isJournalSyncNonTransactional()
Returns whether the journal is synchronized when receiving non-transactional data.
|
boolean |
isJournalSyncTransactional()
Returns whether the journal is synchronized when receiving transactional data.
|
boolean |
isMessageCounterEnabled()
Returns whether message counter is enabled for this server.
|
boolean |
isPersistDeliveryCountBeforeDelivery()
Returns whether delivery count is persisted before messages are delivered to the consumers.
|
boolean |
isPersistenceEnabled()
Returns whether this server is using persistence and store data.
|
boolean |
isPersistIDCache()
Returns whether message ID cache is persisted.
|
boolean |
isReplicaSync()
Returns whether the initial replication synchronization process with the backup server is complete; applicable for
either the live or backup server.
|
boolean |
isSecurityEnabled()
Returns whether security is enabled for this server.
|
boolean |
isSharedStore()
Returns whether this server shares its data store with a corresponding live or backup server.
|
boolean |
isStarted()
Return whether this server is started.
|
boolean |
isWildcardRoutingEnabled()
Returns whether wildcard routing is supported by this server.
|
String |
listAddresses(String separator) |
String |
listAddresses(String options,
int page,
int pageSize) |
String |
listAllConsumersAsJSON()
Lists all the consumers connected to this server.
|
String |
listAllSessionsAsJSON()
Lists details about all sessions.
|
String |
listBindingsForAddress(String address) |
String |
listBrokerConnections() |
String[] |
listConnectionIDs()
Lists all the IDs of the connections connected to this server.
|
String |
listConnections(String options,
int page,
int pageSize) |
String |
listConnectionsAsJSON()
Lists all the connections connected to this server.
|
String |
listConsumers(String options,
int page,
int pageSize) |
String |
listConsumersAsJSON(String connectionID)
Lists all the consumers which belongs to the connection specified by the connectionID.
|
default String[] |
listDivertNames()
Jon plugin doesn't recognize an Operation whose name is in
form getXXXX(), so add this one.
|
String[] |
listHeuristicCommittedTransactions()
List transactions which have been heuristically committed.
|
String[] |
listHeuristicRolledBackTransactions()
List transactions which have been heuristically rolled back.
|
String |
listNetworkTopology() |
String |
listPreparedTransactionDetailsAsHTML()
List all the prepared transaction, sorted by date,
oldest first, with details, in HTML format
|
String |
listPreparedTransactionDetailsAsJSON()
List all the prepared transaction, sorted by date,
oldest first, with details, in text format.
|
String[] |
listPreparedTransactions()
List all the prepared transaction, sorted by date, oldest first.
|
String |
listProducers(String options,
int page,
int pageSize) |
String |
listProducersInfoAsJSON() |
String |
listQueues(String options,
int page,
int pageSize) |
String[] |
listRemoteAddresses()
Lists the addresses of all the clients connected to this address.
|
String[] |
listRemoteAddresses(String ipAddress)
Lists the addresses of the clients connected to this address which matches the specified IP address.
|
String[] |
listSessions(String connectionID)
Lists all the sessions IDs for the specified connection ID.
|
String |
listSessions(String options,
int page,
int pageSize) |
String |
listSessionsAsJSON(String connectionID)
Lists details about all the sessions for the specified connection ID.
|
String |
listUser(String username)
List the information about a user or all users if no username is supplied (only applicable when using the JAAS PropertiesLoginModule or the ActiveMQBasicSecurityManager).
|
void |
removeAddressSettings(String addressMatch) |
void |
removeSecuritySettings(String addressMatch) |
void |
removeUser(String username)
Remove a user (only applicable when using the JAAS PropertiesLoginModule or the ActiveMQBasicSecurityManager).
|
void |
resetAllMessageCounterHistories()
Reset histories for all message counters.
|
void |
resetAllMessageCounters()
Reset all message counters.
|
void |
resetUser(String username,
String password,
String roles)
Set new properties on an existing user (only applicable when using the JAAS PropertiesLoginModule or the ActiveMQBasicSecurityManager).
|
void |
resetUser(String username,
String password,
String roles,
boolean plaintext)
Set new properties on an existing user (only applicable when using the JAAS PropertiesLoginModule or the ActiveMQBasicSecurityManager).
|
boolean |
rollbackPreparedTransaction(String transactionAsBase64)
Heuristically rolls back a prepared transaction.
|
void |
scaleDown(String connector) |
void |
setFailoverOnServerShutdown(boolean failoverOnServerShutdown)
do any clients failover on a server shutdown
|
void |
setMessageCounterMaxDayCount(int count)
Sets the maximum number of days kept in memory for message counter.
|
void |
setMessageCounterSamplePeriod(long newPeriod)
Sets the sample period to take message counter snapshot.
|
void |
startBrokerConnection(String name) |
void |
stopBrokerConnection(String name) |
String |
updateAddress(String name,
String routingTypes) |
void |
updateDivert(String name,
String forwardingAddress,
String filterString,
String transformerClassName,
Map<String,String> transformerProperties,
String routingType)
update a divert
|
String |
updateQueue(String queueConfiguration)
Update a queue.
|
String |
updateQueue(String name,
String routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers)
Deprecated.
|
String |
updateQueue(String name,
String routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive)
Deprecated.
|
String |
updateQueue(String name,
String routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
String user)
Deprecated.
|
String |
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.
|
String |
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.
|
String |
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.
|
static final String CONNECTION_COUNT_DESCRIPTION
static final String TOTAL_CONNECTION_COUNT_DESCRIPTION
static final String ADDRESS_MEMORY_USAGE_DESCRIPTION
static final String ADDRESS_MEMORY_USAGE_PERCENTAGE_DESCRIPTION
static final String DISK_STORE_USAGE_DESCRIPTION
String getVersion()
boolean isActive()
int getConnectionCount()
long getTotalConnectionCount()
long getTotalMessageCount()
long getTotalMessagesAdded()
long getTotalMessagesAcknowledged()
long getTotalConsumerCount()
boolean isStarted()
String[] getIncomingInterceptorClassNames()
Interceptor
String[] getOutgoingInterceptorClassNames()
Interceptor
boolean isClustered()
int getScheduledThreadPoolMaxSize()
int getThreadPoolMaxSize()
long getSecurityInvalidationInterval()
boolean isSecurityEnabled()
String getBindingsDirectory()
String getJournalDirectory()
String getJournalType()
NIO
or ASYNCIO
).boolean isJournalSyncTransactional()
boolean isJournalSyncNonTransactional()
int getJournalFileSize()
int getJournalMinFiles()
int getJournalMaxIO()
int getJournalBufferSize()
int getJournalPoolFiles()
int getJournalBufferTimeout()
void setFailoverOnServerShutdown(boolean failoverOnServerShutdown) throws Exception
Exception
boolean isFailoverOnServerShutdown()
int getJournalCompactMinFiles()
int getJournalCompactPercentage()
boolean isPersistenceEnabled()
boolean isCreateBindingsDir()
boolean isCreateJournalDir()
boolean isMessageCounterEnabled()
int getMessageCounterMaxDayCount()
void setMessageCounterMaxDayCount(int count) throws Exception
count
- value must be greater than 0Exception
long getMessageCounterSamplePeriod()
void setMessageCounterSamplePeriod(long newPeriod) throws Exception
newPeriod
- value must be greater than 1000msException
boolean isBackup()
true
if this server is a backup, false
if it is a live server.
false
.boolean isSharedStore()
String getPagingDirectory()
boolean isPersistDeliveryCountBeforeDelivery()
long getConnectionTTLOverride()
String getManagementAddress()
String getNodeID()
String getManagementNotificationAddress()
int getIDCacheSize()
boolean isPersistIDCache()
String getLargeMessagesDirectory()
boolean isWildcardRoutingEnabled()
long getTransactionTimeout()
long getTransactionTimeoutScanPeriod()
long getMessageExpiryScanPeriod()
@Deprecated long getMessageExpiryThreadPriority()
boolean isAsyncConnectionExecutionEnabled()
Object[] getConnectors() throws Exception
Exception
String getConnectorsAsJSON() throws Exception
Exception
String[] getAddressNames()
String[] getQueueNames()
String getUptime()
long getUptimeMillis()
boolean isReplicaSync()
int getDiskScanPeriod()
int getMaxDiskUsage()
long getGlobalMaxSize()
long getAddressMemoryUsage()
double getDiskStoreUsage()
int getAddressMemoryUsagePercentage()
String getHAPolicy()
long getAuthenticationCacheSize()
long getAuthorizationCacheSize()
boolean freezeReplication()
String createAddress(String name, String routingTypes) throws Exception
Exception
String updateAddress(String name, String routingTypes) throws Exception
Exception
@Deprecated void createQueue(String address, String name) throws Exception
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.address
- address to bind the queue toname
- name of the queueException
@Deprecated void createQueue(String address, String name, String routingType) throws Exception
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.address
- address to bind the queue toname
- name of the queueroutingType
- The routing type used for this address, MULTICAST or ANYCASTException
@Deprecated void createQueue(String address, String name, boolean durable) throws Exception
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.address
- address to bind the queue toname
- name of the queuedurable
- whether the queue is durableException
@Deprecated void createQueue(String address, String name, boolean durable, String routingType) throws Exception
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.address
- address to bind the queue toname
- name of the queuedurable
- whether the queue is durableroutingType
- The routing type used for this address, MULTICAST or ANYCASTException
@Deprecated void createQueue(String address, String name, String filter, boolean durable) throws Exception
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.address
- address to bind the queue toname
- name of the queuefilter
- of the queuedurable
- whether the queue is durableException
@Deprecated void createQueue(String address, String name, String filter, boolean durable, String routingType) throws Exception
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.address
- address to bind the queue toname
- name of the queuefilter
- of the queuedurable
- whether the queue is durableroutingType
- The routing type used for this address, MULTICAST or ANYCASTException
@Deprecated String 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) throws Exception
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.address
- address to bind the queue toroutingType
- the routing type used for this address, MULTICAST
or ANYCAST
name
- name of the queuefilterStr
- filter of the queuedurable
- is the queue durable?maxConsumers
- the maximum number of consumers allowed on this queue at any one timepurgeOnNoConsumers
- delete this queue when the last consumer disconnectsexclusive
- if the queue should route exclusively to one consumerlastValue
- use last-value semanticsconsumersBeforeDispatch
- number of consumers needed before dispatch can startdelayBeforeDispatch
- delay to wait before dispatching if number of consumers before dispatch is not metautoCreateAddress
- create an address with default values should a matching address not be foundException
@Deprecated String 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) throws Exception
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.address
- address to bind the queue toroutingType
- the routing type used for this address, MULTICAST
or ANYCAST
name
- name of the queuefilterStr
- filter of the queuedurable
- is the queue durable?maxConsumers
- the maximum number of consumers allowed on this queue at any one timepurgeOnNoConsumers
- delete this queue when the last consumer disconnectsexclusive
- if the queue should route exclusively to one consumerlastValue
- use last-value semanticsconsumersBeforeDispatch
- number of consumers needed before dispatch can startdelayBeforeDispatch
- delay to wait before dispatching if number of consumers before dispatch is not metautoCreateAddress
- create an address with default values should a matching address not be foundException
@Deprecated String 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) throws Exception
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.address
- address to bind the queue toroutingType
- the routing type used for this address, MULTICAST
or ANYCAST
name
- name of the queuefilterStr
- filter of the queuedurable
- is the queue durable?maxConsumers
- the maximum number of consumers allowed on this queue at any one timepurgeOnNoConsumers
- delete this queue when the last consumer disconnectsexclusive
- if the queue should route exclusively to one consumerlastValue
- use last-value semanticsconsumersBeforeDispatch
- number of consumers needed before dispatch can startdelayBeforeDispatch
- delay to wait before dispatching if number of consumers before dispatch is not metautoCreateAddress
- create an address with default values should a matching address not be foundException
@Deprecated String 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) throws Exception
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.address
- address to bind the queue toroutingType
- the routing type used for this address, MULTICAST
or ANYCAST
name
- name of the queuefilterStr
- filter of the queuedurable
- is the queue durable?maxConsumers
- the maximum number of consumers allowed on this queue at any one timepurgeOnNoConsumers
- delete this queue when the last consumer disconnectsexclusive
- if the queue should route exclusively to one consumerlastValue
- use last-value semanticsconsumersBeforeDispatch
- number of consumers needed before dispatch can startdelayBeforeDispatch
- delay to wait before dispatching if number of consumers before dispatch is not metautoCreateAddress
- create an address with default values should a matching address not be foundringSize
- the size this queue should maintain according to ring semanticsException
@Deprecated String createQueue(String address, String routingType, String name, String filterStr, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress) throws Exception
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.address
- address to bind the queue toroutingType
- the routing type used for this address, MULTICAST
or ANYCAST
name
- name of the queuefilterStr
- filter of the queuedurable
- is the queue durable?maxConsumers
- the maximum number of consumers allowed on this queue at any one timepurgeOnNoConsumers
- delete this queue when the last consumer disconnectsautoCreateAddress
- create an address with default values should a matching address not be foundException
String createQueue(String queueConfiguration) throws Exception
ActiveMQQueueExistsException
) exception if the queue already exists.queueConfiguration
- the configuration of the queue in JSON formatException
String createQueue(String queueConfiguration, boolean ignoreIfExists) throws Exception
ActiveMQQueueExistsException
) exception if the queue already exists and ignoreIfExists
is false
.queueConfiguration
- the configuration of the queue in JSON formatignoreIfExists
- whether or not to simply return without an exception if the queue existsException
String updateQueue(String queueConfiguration) throws Exception
queueConfiguration
- the configuration of the queue in JSON formatException
@Deprecated String updateQueue(String name, String routingType, Integer maxConsumers, Boolean purgeOnNoConsumers) throws Exception
name
- name of the queueroutingType
- the routing type used for this address, MULTICAST
or ANYCAST
maxConsumers
- the maximum number of consumers allowed on this queue at any one timepurgeOnNoConsumers
- delete this queue when the last consumer disconnectsException
@Deprecated String updateQueue(String name, String routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive) throws Exception
name
- name of the queueroutingType
- the routing type used for this address, MULTICAST
or ANYCAST
maxConsumers
- the maximum number of consumers allowed on this queue at any one timepurgeOnNoConsumers
- delete this queue when the last consumer disconnectsexclusive
- if the queue should route exclusively to one consumerException
@Deprecated String updateQueue(String name, String routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, String user) throws Exception
name
- name of the queueroutingType
- the routing type used for this address, MULTICAST
or ANYCAST
maxConsumers
- the maximum number of consumers allowed on this queue at any one timepurgeOnNoConsumers
- delete this queue when the last consumer disconnectsexclusive
- if the queue should route exclusively to one consumeruser
- the user associated with this queueException
@Deprecated String 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) throws Exception
name
- name of the queueroutingType
- the routing type used for this address, MULTICAST
or ANYCAST
filter
- the filter to use on the queuemaxConsumers
- the maximum number of consumers allowed on this queue at any one timepurgeOnNoConsumers
- delete this queue when the last consumer disconnectsexclusive
- if the queue should route exclusively to one consumergroupRebalance
- if the queue should rebalance groups when a consumer is addedgroupBuckets
- number of buckets that should be used for message groups, -1 (default) is unlimited, and groups by raw key insteadnonDestructive
- If the queue is non-destructiveconsumersBeforeDispatch
- number of consumers needed before dispatch can startdelayBeforeDispatch
- delay to wait before dispatching if number of consumers before dispatch is not metuser
- the user associated with this queueException
@Deprecated String 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) throws Exception
name
- name of the queueroutingType
- the routing type used for this address, MULTICAST
or ANYCAST
filter
- the filter to use on the queuemaxConsumers
- the maximum number of consumers allowed on this queue at any one timepurgeOnNoConsumers
- delete this queue when the last consumer disconnectsexclusive
- if the queue should route exclusively to one consumergroupRebalance
- if the queue should rebalance groups when a consumer is addedgroupBuckets
- number of buckets that should be used for message groups, -1 (default) is unlimited, and groups by raw key insteadgroupFirstKey
- key used to mark a message is first in a group for a consumernonDestructive
- If the queue is non-destructiveconsumersBeforeDispatch
- number of consumers needed before dispatch can startdelayBeforeDispatch
- delay to wait before dispatching if number of consumers before dispatch is not metuser
- the user associated with this queueException
@Deprecated String 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) throws Exception
name
- name of the queueroutingType
- the routing type used for this address, MULTICAST
or ANYCAST
filter
- the filter to use on the queuemaxConsumers
- the maximum number of consumers allowed on this queue at any one timepurgeOnNoConsumers
- delete this queue when the last consumer disconnectsexclusive
- if the queue should route exclusively to one consumergroupRebalance
- if the queue should rebalance groups when a consumer is addedgroupBuckets
- number of buckets that should be used for message groups, -1 (default) is unlimited, and groups by raw key insteadgroupFirstKey
- key used to mark a message is first in a group for a consumernonDestructive
- If the queue is non-destructiveconsumersBeforeDispatch
- number of consumers needed before dispatch can startdelayBeforeDispatch
- delay to wait before dispatching if number of consumers before dispatch is not metuser
- the user associated with this queueringSize
- the size this queue should maintain according to ring semanticsException
@Deprecated void deployQueue(String address, String name, String filter) throws Exception
address
is null
it will be defaulted to name
.
address
- address to bind the queue toname
- name of the queuefilter
- of the queueException
@Deprecated void deployQueue(String address, String name, String filter, boolean durable) throws Exception
address
is null
it will be defaulted to name
.
address
- address to bind the queue toname
- name of the queuefilter
- of the queuedurable
- whether the queue is durableException
void destroyQueue(String name) throws Exception
Exception
void destroyQueue(String name, boolean removeConsumers) throws Exception
Exception
void destroyQueue(String name, boolean removeConsumers, boolean autoDeleteAddress) throws Exception
Exception
void enableMessageCounters() throws Exception
Exception
void disableMessageCounters() throws Exception
Exception
void resetAllMessageCounters() throws Exception
Exception
void resetAllMessageCounterHistories() throws Exception
Exception
String[] listPreparedTransactions() throws Exception
Exception
commitPreparedTransaction(String)
,
rollbackPreparedTransaction(String)
String listPreparedTransactionDetailsAsJSON() throws Exception
Exception
String listPreparedTransactionDetailsAsHTML() throws Exception
Exception
String[] listHeuristicCommittedTransactions() throws Exception
Exception
String[] listHeuristicRolledBackTransactions() throws Exception
Exception
boolean commitPreparedTransaction(String transactionAsBase64) throws Exception
transactionAsBase64
- base 64 representation of a prepare transactiontrue
if the transaction was successfully committed, false
elseException
listPreparedTransactions()
boolean rollbackPreparedTransaction(String transactionAsBase64) throws Exception
transactionAsBase64
- base 64 representation of a prepare transactiontrue
if the transaction was successfully rolled back, false
elseException
listPreparedTransactions()
String[] listRemoteAddresses() throws Exception
Exception
String[] listRemoteAddresses(String ipAddress) throws Exception
Exception
boolean closeConnectionsForAddress(String ipAddress) throws Exception
Exception
boolean closeConsumerConnectionsForAddress(String address) throws Exception
Exception
boolean closeConnectionsForUser(String address) throws Exception
Exception
boolean closeConnectionWithID(String ID) throws Exception
Exception
boolean closeSessionWithID(String connectionID, String ID) throws Exception
Exception
boolean closeConsumerWithID(String sessionID, String ID) throws Exception
Exception
String[] listConnectionIDs() throws Exception
Exception
String listConnectionsAsJSON() throws Exception
[ { "creationTime": 1469240429671, "sessionCount": 1, "implementation": "RemotingConnectionImpl", "connectionID": "1648309901", "clientAddress": "\/127.0.0.1:57649" } ]
Exception
String listConsumersAsJSON(String connectionID) throws Exception
[ { "filter": "color = 'RED'", "queueName": "2ea5b050-28bf-4ee2-9b24-b73f5983192a", "creationTime": 1469239602459, "deliveringCount": 0, "consumerID": 1, "browseOnly": true, "connectionID": "1963ece3-507a-11e6-94ff-e8b1fc439540", "sessionID": "19676f55-507a-11e6-94ff-e8b1fc439540" } ]
Exception
String listAllConsumersAsJSON() throws Exception
[ { "queueName": "fa87c64c-0a38-4697-8421-72e34d17429d", "creationTime": 1469235956168, "deliveringCount": 0, "consumerID": 0, "browseOnly": false, "connectionID": "9c0d42e7-5071-11e6-9e29-e8b1fc439540", "sessionID": "9c0d9109-5071-11e6-9e29-e8b1fc439540" } ]
Exception
String listSessionsAsJSON(String connectionID) throws Exception
[ { "principal": "myUser", "creationTime": 1469240773157, "consumerCount": 0, "sessionID": "d33d10db-507c-11e6-9e47-e8b1fc439540" } ]
Exception
String listAllSessionsAsJSON() throws Exception
[ { "sessionID":"e71d61d7-2176-11e8-9057-a0afbd82eaba", "creationTime":1520365520212, "consumerCount":1, "principal":"myUser" }, { "sessionID":"e718a6e6-2176-11e8-9057-a0afbd82eaba", "creationTime":1520365520191, "consumerCount":0, "principal":"guest" } ]
Exception
String[] listSessions(String connectionID) throws Exception
Exception
void addSecuritySettings(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles) throws Exception
Exception
void addSecuritySettings(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles, String browseRoles) throws Exception
Exception
void addSecuritySettings(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles, String browseRoles, String createAddressRoles, String deleteAddressRoles) throws Exception
Exception
void removeSecuritySettings(String addressMatch) throws Exception
Exception
void 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) throws Exception
Exception
void 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) throws Exception
Exception
void 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) throws Exception
Exception
void 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) throws Exception
Exception
void 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) throws Exception
Exception
void removeAddressSettings(String addressMatch) throws Exception
Exception
String getAddressSettingsAsJSON(String addressMatch) throws Exception
Exception
String[] getDivertNames()
default String[] listDivertNames()
void createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName) throws Exception
Exception
void createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName, String routingType) throws Exception
Exception
void createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName, Map<String,String> transformerProperties, String routingType) throws Exception
Exception
void createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName, String transformerPropertiesAsJSON, String routingType) throws Exception
Exception
void updateDivert(String name, String forwardingAddress, String filterString, String transformerClassName, Map<String,String> transformerProperties, String routingType) throws Exception
Exception
String[] getBridgeNames()
void 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) throws Exception
Exception
void 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) throws Exception
Exception
void 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) throws Exception
Exception
void 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) throws Exception
Exception
String listBrokerConnections()
void createConnectorService(String name, String factoryClass, Map<String,Object> parameters) throws Exception
Exception
void destroyConnectorService(String name) throws Exception
Exception
String[] getConnectorServices()
String getAddressInfo(String address) throws ActiveMQAddressDoesNotExistException
String listBindingsForAddress(String address) throws Exception
Exception
String listConnections(String options, int page, int pageSize) throws Exception
Exception
String listSessions(String options, int page, int pageSize) throws Exception
Exception
String listConsumers(String options, int page, int pageSize) throws Exception
Exception
String listProducers(String options, int page, int pageSize) throws Exception
Exception
String listAddresses(String options, int page, int pageSize) throws Exception
Exception
String listQueues(String options, int page, int pageSize) throws Exception
Exception
String[] getQueueNames(String routingType)
String[] getClusterConnectionNames()
void addUser(String username, String password, String roles, boolean plaintext) throws Exception
username
- password
- roles
- Exception
String listUser(String username) throws Exception
username
- Exception
void removeUser(String username) throws Exception
username
- Exception
void resetUser(String username, String password, String roles) throws Exception
username
- password
- roles
- Exception
void resetUser(String username, String password, String roles, boolean plaintext) throws Exception
username
- password
- roles
- plaintext
- Exception
Copyright © 2021 JBoss by Red Hat. All rights reserved.