boolean |
AddressControl.clearDuplicateIdCache() |
|
Object[] |
ActiveMQServerControl.getAcceptors() |
Returns the acceptors configured for this server.
|
String |
ActiveMQServerControl.getAcceptorsAsJSON() |
Returns the acceptors configured for this server using JSON serialization.
|
long |
QueueControl.getAcknowledgeAttempts() |
Returns the number of messages added to this queue since it was created.
|
long |
ActiveMQServerControl.getActivationSequence() |
Returns the current activation sequence number of this server.
|
String |
AddressControl.getAddress() |
Returns the managed address.
|
String |
ClusterConnectionControl.getAddress() |
Returns the address used by this cluster connection.
|
String |
DivertControl.getAddress() |
Returns the origin address used by this divert.
|
String |
QueueControl.getAddress() |
Returns the address this queue is bound to.
|
int |
ActiveMQServerControl.getAddressCount() |
Returns the number of addresses created on this server.
|
int |
AddressControl.getAddressLimitPercent() |
Returns the % of memory limit that is currently in use
|
long |
ActiveMQServerControl.getAddressMemoryUsage() |
Returns the memory used by all the addresses on broker for in-memory messages
|
int |
ActiveMQServerControl.getAddressMemoryUsagePercentage() |
Returns the memory used by all the addresses on broker as a percentage of the global-max-size
|
String[] |
ActiveMQServerControl.getAddressNames() |
Returns the names of the addresses created on this server.
|
long |
AddressControl.getAddressSize() |
Returns the number of estimated bytes being used by all the queue(s) bound to this address; used to control paging and blocking.
|
String[] |
AddressControl.getAllQueueNames() |
Returns the names of both the local and remote queue(s) bound to this address.
|
long |
ActiveMQServerControl.getAuthenticationCacheSize() |
Returns the runtime size of the authentication cache
|
long |
ActiveMQServerControl.getAuthorizationCacheSize() |
Returns the runtime size of the authorization cache
|
String[] |
AddressControl.getBindingNames() |
Returns the names of all bindings (both queues and diverts) bound to this address
|
String |
ActiveMQServerControl.getBindingsDirectory() |
Returns the file system directory used to store bindings.
|
Map<String,Object> |
ClusterConnectionControl.getBridgeMetrics(String nodeId) |
The bridge metrics for the given node in the cluster connection
The messagesPendingAcknowledgement counter is incremented when the bridge is has forwarded a message but is waiting acknowledgement from the other broker.
|
String[] |
ActiveMQServerControl.getBridgeNames() |
|
long |
BaseBroadcastGroupControl.getBroadcastPeriod() |
Returns the period used by this broadcast group.
|
String |
JGroupsChannelBroadcastGroupControl.getChannelName() |
Returns the JGroups channel name
|
String |
JGroupsFileBroadcastGroupControl.getChannelName() |
Returns jgroups channel name
|
int |
ActiveMQServerControl.getConnectionCount() |
Returns the number of clients connected to this server.
|
long |
ActiveMQServerControl.getConnectionTTLOverride() |
Returns the connection time to live.
|
Object[] |
BaseBroadcastGroupControl.getConnectorPairs() |
Returns the pairs of live-backup connectors that are broadcasted by this broadcast group.
|
String |
BaseBroadcastGroupControl.getConnectorPairsAsJSON() |
Returns the pairs of live-backup connectors that are broadcasted by this broadcast group
using JSON serialization.
|
Object[] |
ActiveMQServerControl.getConnectors() |
Returns the connectors configured for this server.
|
String |
ActiveMQServerControl.getConnectorsAsJSON() |
Returns the connectors configured for this server using JSON serialization.
|
String[] |
ActiveMQServerControl.getConnectorServices() |
|
int |
QueueControl.getConsumerCount() |
Returns the number of consumers consuming messages from this queue.
|
int |
QueueControl.getConsumersBeforeDispatch() |
Return the Consumers Before Dispatch
|
long |
AddressControl.getCurrentDuplicateIdCacheSize() |
|
long |
ActiveMQServerControl.getCurrentTimeMillis() |
|
String |
QueueControl.getDeadLetterAddress() |
Returns the dead-letter address associated with this queue.
|
long |
QueueControl.getDelayBeforeDispatch() |
Return the Consumers Before Dispatch
|
int |
QueueControl.getDeliveringCount() |
Returns the number of messages that this queue is currently delivering to its consumers.
|
long |
QueueControl.getDeliveringSize() |
Returns the persistent size of messages that this queue is currently delivering to its consumers.
|
String |
BridgeControl.getDiscoveryGroupName() |
Returns the name of the discovery group used by this bridge.
|
String |
ClusterConnectionControl.getDiscoveryGroupName() |
Returns the name of the discovery group used by this cluster connection.
|
int |
ActiveMQServerControl.getDiskScanPeriod() |
Returns how often the server checks for disk space usage.
|
double |
ActiveMQServerControl.getDiskStoreUsage() |
Returns the percentage of total disk store use
|
String[] |
ActiveMQServerControl.getDivertNames() |
|
int |
QueueControl.getDurableDeliveringCount() |
Returns the number of durable messages that this queue is currently delivering to its consumers.
|
long |
QueueControl.getDurableDeliveringSize() |
Returns the size of durable messages that this queue is currently delivering to its consumers.
|
long |
QueueControl.getDurableMessageCount() |
Returns the number of durable messages currently in this queue.
|
long |
QueueControl.getDurablePersistentSize() |
Returns the persistent size of durable messages currently in this queue.
|
long |
QueueControl.getDurableScheduledCount() |
Returns the number of durable scheduled messages in this queue.
|
long |
QueueControl.getDurableScheduledSize() |
Returns the size of durable scheduled messages in this queue.
|
String |
QueueControl.getExpiryAddress() |
Returns the expiry address associated with this queue.
|
String |
AcceptorControl.getFactoryClassName() |
Returns the class name of the AcceptorFactory implementation
used by this acceptor.
|
String |
JGroupsFileBroadcastGroupControl.getFile() |
Returns the jgroups file name
|
String |
JGroupsFileBroadcastGroupControl.getFileContents() |
Returns the contents of the jgroups file
|
String |
DivertControl.getFilter() |
Returns the filter used by this divert.
|
String |
QueueControl.getFilter() |
Returns the filter associated with this queue.
|
String |
BridgeControl.getFilterString() |
Returns the filter string associated with this bridge.
|
Long |
QueueControl.getFirstMessageAge() |
Returns the age of the first message in milliseconds.
|
String |
QueueControl.getFirstMessageAsJSON() |
Returns the first message on the queue as JSON
|
Long |
QueueControl.getFirstMessageTimestamp() |
Returns the timestamp of the first message in milliseconds.
|
String |
BridgeControl.getForwardingAddress() |
Returns the address this bridge will forward messages to.
|
String |
DivertControl.getForwardingAddress() |
Returns the forwarding address used by this divert.
|
long |
ActiveMQServerControl.getGlobalMaxSize() |
Returns the global max bytes limit for in-memory messages.
|
String |
BroadcastGroupControl.getGroupAddress() |
Returns the address this broadcast group is broadcasting to.
|
int |
QueueControl.getGroupBuckets() |
Will return the group buckets.
|
int |
QueueControl.getGroupCount() |
Will return the current number of active groups.
|
String |
QueueControl.getGroupFirstKey() |
Will return the header key to notify a consumer of a group change.
|
int |
BroadcastGroupControl.getGroupPort() |
Returns the port this broadcast group is broadcasting to.
|
String |
ActiveMQServerControl.getHAPolicy() |
|
long |
QueueControl.getID() |
Returns this queue ID.
|
int |
ActiveMQServerControl.getIDCacheSize() |
Returns the size of the cache for pre-creating message IDs.
|
String[] |
ActiveMQServerControl.getIncomingInterceptorClassNames() |
Returns the list of interceptors used by this server for incoming messages.
|
int |
ActiveMQServerControl.getJournalBufferSize() |
Returns the size of the internal buffer on the journal.
|
int |
ActiveMQServerControl.getJournalBufferTimeout() |
Returns the timeout (in nanoseconds) used to flush internal buffers on the journal.
|
int |
ActiveMQServerControl.getJournalCompactMinFiles() |
Returns the minimal number of journal files before compacting.
|
int |
ActiveMQServerControl.getJournalCompactPercentage() |
Return the percentage of live data before compacting the journal.
|
String |
ActiveMQServerControl.getJournalDirectory() |
Returns the file system directory used to store journal log.
|
int |
ActiveMQServerControl.getJournalFileSize() |
Returns the size (in bytes) of each journal files.
|
int |
ActiveMQServerControl.getJournalMaxIO() |
Returns the maximum number of write requests that can be in the AIO queue at any given time.
|
int |
ActiveMQServerControl.getJournalMinFiles() |
Returns the number of journal files to pre-create.
|
int |
ActiveMQServerControl.getJournalPoolFiles() |
Number of files that would be acceptable to keep on a pool
|
String |
ActiveMQServerControl.getJournalType() |
Returns the type of journal used by this server (either NIO or ASYNCIO ).
|
String |
ActiveMQServerControl.getLargeMessagesDirectory() |
Returns the file system directory used to store large messages.
|
String |
QueueControl.getLastValueKey() |
The key used for the last value queues
|
int |
BroadcastGroupControl.getLocalBindPort() |
Returns the local port this broadcast group is bound to.
|
String |
ActiveMQServerControl.getManagementAddress() |
Returns the management address of this server.
|
String |
ActiveMQServerControl.getManagementNotificationAddress() |
Returns the management notification address of this server.
|
int |
QueueControl.getMaxConsumers() |
|
int |
ActiveMQServerControl.getMaxDiskUsage() |
Returns the disk use max limit.
|
int |
ClusterConnectionControl.getMaxHops() |
Returns the maximum number of hops used by this cluster connection.
|
long |
BridgeControl.getMaxRetryInterval() |
Returns the max retry interval used by this bridge.
|
long |
AddressControl.getMessageCount() |
|
long |
QueueControl.getMessageCount() |
Returns the number of messages currently in this queue.
|
int |
ActiveMQServerControl.getMessageCounterMaxDayCount() |
Returns the maximum number of days kept in memory for message counter.
|
long |
ActiveMQServerControl.getMessageCounterSamplePeriod() |
Returns the sample period (in milliseconds) to take message counter snapshot.
|
long |
ActiveMQServerControl.getMessageExpiryScanPeriod() |
Returns the frequency (in milliseconds) to scan messages to detect which messages
have expired.
|
long |
ActiveMQServerControl.getMessageExpiryThreadPriority() |
Deprecated.
|
String |
ClusterConnectionControl.getMessageLoadBalancingType() |
Return the type of message load balancing strategy this bridge will use.
|
long |
BridgeControl.getMessagesAcknowledged() |
The messagesAcknowledged counter is the number of messages actually received by the remote broker.
|
long |
ClusterConnectionControl.getMessagesAcknowledged() |
The messagesAcknowledged counter is the number of messages actually received by a remote broker for all
bridges in this cluster connection
This is a cumulative total and the number of outstanding pending messages for the cluster connection
can be computed by subtracting messagesAcknowledged from messagesPendingAcknowledgement.
|
long |
QueueControl.getMessagesAcknowledged() |
Returns the number of messages added to this queue since it was created.
|
long |
QueueControl.getMessagesAdded() |
Returns the number of messages added to this queue since it was created.
|
long |
QueueControl.getMessagesExpired() |
Returns the number of messages expired from this queue since it was created.
|
long |
QueueControl.getMessagesKilled() |
Returns the number of messages removed from this queue since it was created due to exceeding the max delivery attempts.
|
long |
BridgeControl.getMessagesPendingAcknowledgement() |
The messagesPendingAcknowledgement counter is incremented when the bridge is has forwarded a message but
is waiting acknowledgement from the other broker.
|
long |
ClusterConnectionControl.getMessagesPendingAcknowledgement() |
The messagesPendingAcknowledgement counter is incremented when any bridge in the cluster connection has
forwarded a message and is waiting acknowledgement from the other broker.
|
Map<String,Object> |
BridgeControl.getMetrics() |
The bridge metrics for this bridge
The messagesPendingAcknowledgement counter is incremented when the bridge is has forwarded a message but is waiting acknowledgement from the other broker.
|
Map<String,Object> |
ClusterConnectionControl.getMetrics() |
The current metrics for this cluster connection (aggregate over all bridges to other nodes)
The messagesPendingAcknowledgement counter is incremented when any bridge in the cluster connection has
forwarded a message and is waiting acknowledgement from the other broker.
|
String |
AcceptorControl.getName() |
Returns the name of the acceptor
|
String |
ActiveMQServerControl.getName() |
Returns this server's name.
|
String |
BaseBroadcastGroupControl.getName() |
Returns the configuration name of this broadcast group.
|
String |
BridgeControl.getName() |
Returns the name of this bridge
|
String |
ClusterConnectionControl.getName() |
Returns the configuration name of this cluster connection.
|
String |
QueueControl.getName() |
Returns the name of this queue.
|
String |
ActiveMQServerControl.getNodeID() |
Returns the node ID of this server.
|
String |
ClusterConnectionControl.getNodeID() |
Returns the node ID used by this cluster connection.
|
Map<String,String> |
ClusterConnectionControl.getNodes() |
Returns a map of the nodes connected to this cluster connection.
|
long |
AddressControl.getNumberOfBytesPerPage() |
Returns the number of bytes used by each page for this address.
|
long |
AddressControl.getNumberOfMessages() |
Deprecated.
|
long |
AddressControl.getNumberOfPages() |
Returns the number of pages used by this address.
|
String[] |
ActiveMQServerControl.getOutgoingInterceptorClassNames() |
Returns the list of interceptors used by this server for outgoing messages.
|
String |
ActiveMQServerControl.getPagingDirectory() |
Returns the file system directory used to store paging files.
|
Map<String,Object> |
AcceptorControl.getParameters() |
Returns the parameters used to configure this acceptor
|
long |
QueueControl.getPersistentSize() |
Returns the persistent size of all messages currently in this queue.
|
int |
QueueControl.getPreparedTransactionMessageCount() |
Will return the number of messages stuck in prepared transactions
|
long |
ClusterConnectionControl.getProducerWindowSize() |
|
int |
ActiveMQServerControl.getQueueCount() |
Returns the number of queues created on this server.
|
String |
BridgeControl.getQueueName() |
Returns the name of the queue this bridge is consuming messages from.
|
String[] |
ActiveMQServerControl.getQueueNames() |
Returns the names of the queues created on this server.
|
String[] |
AddressControl.getQueueNames() |
Returns the names of the local queue(s) bound to this address.
|
int |
BridgeControl.getReconnectAttempts() |
Returns the number of reconnection attempts used by this bridge.
|
String[] |
AddressControl.getRemoteQueueNames() |
Returns the names of the remote queue(s) bound to this address.
|
long |
BridgeControl.getRetryInterval() |
Returns the retry interval used by this bridge.
|
long |
ClusterConnectionControl.getRetryInterval() |
Returns the connection retry interval used by this cluster connection.
|
double |
BridgeControl.getRetryIntervalMultiplier() |
Returns the retry interval multiplier used by this bridge.
|
long |
QueueControl.getRingSize() |
Will return the ring size.
|
Object[] |
AddressControl.getRoles() |
Returns the roles (name and permissions) associated with this address.
|
String |
AddressControl.getRolesAsJSON() |
Returns the roles (name and permissions) associated with this address
using JSON serialization.
|
long |
AddressControl.getRoutedMessageCount() |
Returns the number of messages routed to one or more bindings
|
String |
DivertControl.getRoutingName() |
Returns the routing name of this divert.
|
String |
DivertControl.getRoutingType() |
Returns the routing type used by this divert.
|
String |
QueueControl.getRoutingType() |
The routing type of this queue.
|
String[] |
AddressControl.getRoutingTypes() |
|
String |
AddressControl.getRoutingTypesAsJSON() |
|
long |
QueueControl.getScheduledCount() |
Returns the number of scheduled messages in this queue.
|
long |
QueueControl.getScheduledSize() |
Returns the size of scheduled messages in this queue.
|
int |
ActiveMQServerControl.getScheduledThreadPoolMaxSize() |
Returns the maximum number of threads in the scheduled thread pool.
|
long |
ActiveMQServerControl.getSecurityInvalidationInterval() |
Returns the interval time (in milliseconds) to invalidate security credentials.
|
String[] |
BridgeControl.getStaticConnectors() |
Returns any list of static connectors used by this bridge
|
Object[] |
ClusterConnectionControl.getStaticConnectors() |
Returns the list of static connectors
|
String |
ClusterConnectionControl.getStaticConnectorsAsJSON() |
Returns the list of static connectors as JSON
|
String |
ActiveMQServerControl.getStatus() |
|
int |
ActiveMQServerControl.getThreadPoolMaxSize() |
Returns the maximum number of threads in the thread pool.
|
String |
ClusterConnectionControl.getTopology() |
Return the Topology that this Cluster Connection knows about
|
long |
ActiveMQServerControl.getTotalConnectionCount() |
Returns the number of clients which have connected to this server since it was started.
|
long |
ActiveMQServerControl.getTotalConsumerCount() |
Returns the number of messages sent to this server since it was started.
|
long |
ActiveMQServerControl.getTotalMessageCount() |
Returns the number of messages in all queues on the server.
|
long |
ActiveMQServerControl.getTotalMessagesAcknowledged() |
Returns the number of messages sent to this server since it was started.
|
long |
ActiveMQServerControl.getTotalMessagesAdded() |
Returns the number of messages sent to this server since it was started.
|
long |
ActiveMQServerControl.getTransactionTimeout() |
Returns the timeout (in milliseconds) after which transactions is removed
from the resource manager after it was created.
|
long |
ActiveMQServerControl.getTransactionTimeoutScanPeriod() |
Returns the frequency (in milliseconds) to scan transactions to detect which transactions
have timed out.
|
String |
BridgeControl.getTransformerClassName() |
Return the name of the org.apache.activemq.artemis.core.server.cluster.Transformer implementation associated with this bridge.
|
String |
DivertControl.getTransformerClassName() |
Return the name of the org.apache.activemq.artemis.core.server.cluster.Transformer implementation associated with this divert.
|
Map<String,String> |
BridgeControl.getTransformerProperties() |
Returns a map of the properties configured for the transformer.
|
Map<String,String> |
DivertControl.getTransformerProperties() |
Returns a map of the properties configured for the transformer.
|
String |
BridgeControl.getTransformerPropertiesAsJSON() |
Returns a map of the properties configured for the transformer.
|
String |
DivertControl.getTransformerPropertiesAsJSON() |
Returns a map of the properties configured for the transformer.
|
String |
DivertControl.getUniqueName() |
Returns the cluster-wide unique name of this divert.
|
long |
AddressControl.getUnRoutedMessageCount() |
Returns the number of messages not routed to any bindings
|
String |
ActiveMQServerControl.getUptime() |
Returns the uptime of this server.
|
long |
ActiveMQServerControl.getUptimeMillis() |
Returns the uptime of this server.
|
String |
QueueControl.getUser() |
Returns the user that is associated with creating the queue.
|
String |
ActiveMQServerControl.getVersion() |
Returns this server's version.
|
boolean |
ActiveMQServerControl.isActive() |
|
boolean |
ActiveMQServerControl.isAsyncConnectionExecutionEnabled() |
Returns whether code coming from connection is executed asynchronously or not.
|
boolean |
AddressControl.isAutoCreated() |
Returns whether this address was created automatically in response to client action.
|
boolean |
QueueControl.isAutoDelete() |
Returns whether this queue is available for auto deletion.
|
boolean |
ActiveMQServerControl.isBackup() |
Returns true if this server is a backup, false if it is a primary server.
|
boolean |
ActiveMQServerControl.isClustered() |
Returns whether this server is clustered.
|
boolean |
QueueControl.isConfigurationManaged() |
|
boolean |
ActiveMQServerControl.isCreateBindingsDir() |
Returns whether the bindings directory is created on this server startup.
|
boolean |
ActiveMQServerControl.isCreateJournalDir() |
Returns whether the journal directory is created on this server startup.
|
boolean |
ClusterConnectionControl.isDuplicateDetection() |
Return whether this cluster connection use duplicate detection.
|
boolean |
QueueControl.isDurable() |
Returns whether this queue is durable.
|
boolean |
ActiveMQServerControl.isEmbeddedWebServerStarted() |
|
boolean |
QueueControl.isEnabled() |
|
boolean |
DivertControl.isExclusive() |
Returns whether this divert is exclusive.
|
boolean |
QueueControl.isExclusive() |
|
boolean |
ActiveMQServerControl.isFailoverOnServerShutdown() |
returns if clients failover on a server shutdown
|
boolean |
QueueControl.isGroupRebalance() |
Returns whether the groups of this queue are automatically rebalanced.
|
boolean |
QueueControl.isGroupRebalancePauseDispatch() |
Returns whether the dispatch is paused when groups of this queue are automatically rebalanced.
|
boolean |
BridgeControl.isHA() |
Returns whether this bridge is using high availability
|
boolean |
AddressControl.isInternal() |
Returns whether this address was created for the broker's internal use.
|
boolean |
ActiveMQServerControl.isJournalSyncNonTransactional() |
Returns whether the journal is synchronized when receiving non-transactional data.
|
boolean |
ActiveMQServerControl.isJournalSyncTransactional() |
Returns whether the journal is synchronized when receiving transactional data.
|
boolean |
QueueControl.isLastValue() |
|
boolean |
ActiveMQServerControl.isMessageCounterEnabled() |
Returns whether message counter is enabled for this server.
|
boolean |
AddressControl.isPaging() |
Returns whether this address is paging.
|
boolean |
AddressControl.isPaused() |
|
boolean |
QueueControl.isPaused() |
Returns whether the queue is paused.
|
boolean |
ActiveMQServerControl.isPersistDeliveryCountBeforeDelivery() |
Returns whether delivery count is persisted before messages are delivered to the consumers.
|
boolean |
ActiveMQServerControl.isPersistenceEnabled() |
Returns whether this server is using persistence and store data.
|
boolean |
ActiveMQServerControl.isPersistIDCache() |
Returns whether message ID cache is persisted.
|
boolean |
QueueControl.isPurgeOnNoConsumers() |
|
boolean |
ActiveMQServerControl.isReplicaSync() |
Returns whether the initial replication synchronization process with the backup server is complete; applicable for
either the primary or backup server.
|
boolean |
AddressControl.isRetroactiveResource() |
|
boolean |
DivertControl.isRetroactiveResource() |
|
boolean |
QueueControl.isRetroactiveResource() |
Returns whether this queue is used for a retroactive address.
|
boolean |
ActiveMQServerControl.isSecurityEnabled() |
Returns whether security is enabled for this server.
|
boolean |
ActiveMQServerControl.isSharedStore() |
Returns whether this server shares its data store with a corresponding primary or backup server.
|
boolean |
ActiveMQComponentControl.isStarted() |
Returns true if this component is started, false else.
|
boolean |
ActiveMQServerControl.isStarted() |
Return whether this server is started.
|
boolean |
AddressControl.isTemporary() |
Returns whether this address is temporary.
|
boolean |
QueueControl.isTemporary() |
Returns whether this queue is temporary.
|
boolean |
BridgeControl.isUseDuplicateDetection() |
Returns whether this bridge is using duplicate detection.
|
boolean |
ActiveMQServerControl.isWildcardRoutingEnabled() |
Returns whether wildcard routing is supported by this server.
|
void |
ActiveMQServerControl.rebuildPageCounters() |
|
void |
ActiveMQServerControl.setFailoverOnServerShutdown(boolean failoverOnServerShutdown) |
do any clients failover on a server shutdown
|
void |
ActiveMQServerControl.setMessageCounterMaxDayCount(int count) |
Sets the maximum number of days kept in memory for message counter.
|
void |
ActiveMQServerControl.setMessageCounterSamplePeriod(long newPeriod) |
Sets the sample period to take message counter snapshot.
|