public class ActiveMQServerControlImpl extends AbstractControl implements ActiveMQServerControl, NotificationEmitter, NotificationListener
storageManager| Constructor and Description |
|---|
ActiveMQServerControlImpl(PostOffice postOffice,
Configuration configuration,
ResourceManager resourceManager,
RemotingService remotingService,
ActiveMQServer messagingServer,
MessageCounterManager messageCounterManager,
StorageManager storageManager,
NotificationBroadcasterSupport broadcaster) |
| Modifier and Type | Method and Description |
|---|---|
void |
addAddressSettings(String address,
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 |
addNotificationListener(NotificationListener listener,
NotificationFilter filter,
Object handback) |
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) |
boolean |
closeConnectionsForAddress(String ipAddress)
Closes all the connections of clients connected to this server which matches the specified IP address.
|
boolean |
closeConnectionsForUser(String userName)
Closes all the connections of sessions with a matching user name.
|
boolean |
closeConsumerConnectionsForAddress(String address)
Closes all the connections of clients connected to this server which matches the specified IP address.
|
boolean |
commitPreparedTransaction(String transactionAsBase64)
Heuristically commits a prepared transaction.
|
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 staticConnectorsOrDiscoveryGroup,
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 staticConnectorsOrDiscoveryGroup,
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 |
createQueue(String address,
String name)
Create a durable queue.
|
void |
createQueue(String address,
String name,
boolean durable)
Create a queue.
|
void |
createQueue(String address,
String name,
String filterStr,
boolean durable)
Create a queue.
|
void |
deployQueue(String address,
String name,
String filterString)
Deploy a durable queue.
|
void |
deployQueue(String address,
String name,
String filterStr,
boolean durable)
Deploy a queue.
|
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 |
disableMessageCounters()
Disables message counters for this server.
|
void |
enableMessageCounters()
Enables message counters for this server.
|
protected MBeanAttributeInfo[] |
fillMBeanAttributeInfo() |
protected MBeanOperationInfo[] |
fillMBeanOperationInfo() |
void |
forceFailover() |
String[] |
getAddressNames()
Returns the addresses created on this server.
|
String |
getAddressSettingsAsJSON(String address)
returns the address settings as a JSON string
|
String |
getBindingsDirectory()
Returns the file system directory used to store bindings.
|
String[] |
getBridgeNames() |
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.
|
String[] |
getDivertNames() |
long |
getGlobalMaxSize()
Returns the global max bytes limit for in-memory messages.
|
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.
|
String[] |
getInterceptorClassNames() |
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.
|
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()
Returns the priority of the thread used to scan message expiration.
|
MBeanNotificationInfo[] |
getNotificationInfo() |
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.
|
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 |
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 |
listAllConsumersAsJSON()
Lists all the consumers connected to this server.
|
String[] |
listConnectionIDs()
Lists all the IDs of the connections connected to this server.
|
String |
listConnectionsAsJSON()
Lists all the connections connected to this server.
|
String |
listConsumersAsJSON(String connectionID)
Lists all the consumers which belongs to the connection specified by the connectionID.
|
String[] |
listHeuristicCommittedTransactions()
List transactions which have been heuristically committed.
|
String[] |
listHeuristicRolledBackTransactions()
List transactions which have been heuristically rolled back.
|
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 |
listProducersInfoAsJSON() |
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 |
listSessionsAsJSON(String connectionID)
Lists details about all the sessions for the specified connection ID.
|
String[] |
listTargetAddresses(String sessionID) |
void |
onNotification(Notification notification) |
void |
removeAddressSettings(String addressMatch) |
void |
removeNotificationListener(NotificationListener listener) |
void |
removeNotificationListener(NotificationListener listener,
NotificationFilter filter,
Object handback) |
void |
removeSecuritySettings(String addressMatch) |
void |
resetAllMessageCounterHistories()
Reset histories for all message counters.
|
void |
resetAllMessageCounters()
Reset all message counters.
|
boolean |
rollbackPreparedTransaction(String transactionAsBase64)
Heuristically rolls back a prepared transaction.
|
void |
scaleDown(String connector) |
void |
sendQueueInfoToQueue(String queueName,
String address)
This method is used by ActiveMQ Artemis clustering and must not be called by ActiveMQ Artemis clients.
|
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 |
updateDuplicateIdCache(String address,
Object[] ids) |
blockOnIO, clearIO, getMBeanInfocacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementationpublic ActiveMQServerControlImpl(PostOffice postOffice, Configuration configuration, ResourceManager resourceManager, RemotingService remotingService, ActiveMQServer messagingServer, MessageCounterManager messageCounterManager, StorageManager storageManager, NotificationBroadcasterSupport broadcaster) throws Exception
Exceptionpublic boolean isStarted()
ActiveMQServerControlisStarted in interface ActiveMQServerControlpublic String getVersion()
ActiveMQServerControlgetVersion in interface ActiveMQServerControlpublic boolean isBackup()
ActiveMQServerControltrue if this server is a backup, false if it is a live server.
false.isBackup in interface ActiveMQServerControlpublic boolean isSharedStore()
ActiveMQServerControlisSharedStore in interface ActiveMQServerControlpublic String getBindingsDirectory()
ActiveMQServerControlgetBindingsDirectory in interface ActiveMQServerControlpublic String[] getInterceptorClassNames()
public String[] getIncomingInterceptorClassNames()
ActiveMQServerControlgetIncomingInterceptorClassNames in interface ActiveMQServerControlInterceptorpublic String[] getOutgoingInterceptorClassNames()
ActiveMQServerControlgetOutgoingInterceptorClassNames in interface ActiveMQServerControlInterceptorpublic int getJournalBufferSize()
ActiveMQServerControlgetJournalBufferSize in interface ActiveMQServerControlpublic int getJournalBufferTimeout()
ActiveMQServerControlgetJournalBufferTimeout in interface ActiveMQServerControlpublic void setFailoverOnServerShutdown(boolean failoverOnServerShutdown)
ActiveMQServerControlsetFailoverOnServerShutdown in interface ActiveMQServerControlpublic boolean isFailoverOnServerShutdown()
ActiveMQServerControlisFailoverOnServerShutdown in interface ActiveMQServerControlpublic int getJournalMaxIO()
ActiveMQServerControlgetJournalMaxIO in interface ActiveMQServerControlpublic String getJournalDirectory()
ActiveMQServerControlgetJournalDirectory in interface ActiveMQServerControlpublic int getJournalFileSize()
ActiveMQServerControlgetJournalFileSize in interface ActiveMQServerControlpublic int getJournalMinFiles()
ActiveMQServerControlgetJournalMinFiles in interface ActiveMQServerControlpublic int getJournalCompactMinFiles()
ActiveMQServerControlgetJournalCompactMinFiles in interface ActiveMQServerControlpublic int getJournalCompactPercentage()
ActiveMQServerControlgetJournalCompactPercentage in interface ActiveMQServerControlpublic boolean isPersistenceEnabled()
ActiveMQServerControlisPersistenceEnabled in interface ActiveMQServerControlpublic String getJournalType()
ActiveMQServerControlNIO or ASYNCIO).getJournalType in interface ActiveMQServerControlpublic String getPagingDirectory()
ActiveMQServerControlgetPagingDirectory in interface ActiveMQServerControlpublic int getScheduledThreadPoolMaxSize()
ActiveMQServerControlgetScheduledThreadPoolMaxSize in interface ActiveMQServerControlpublic int getThreadPoolMaxSize()
ActiveMQServerControlgetThreadPoolMaxSize in interface ActiveMQServerControlpublic long getSecurityInvalidationInterval()
ActiveMQServerControlgetSecurityInvalidationInterval in interface ActiveMQServerControlpublic boolean isClustered()
ActiveMQServerControlisClustered in interface ActiveMQServerControlpublic boolean isCreateBindingsDir()
ActiveMQServerControlisCreateBindingsDir in interface ActiveMQServerControlpublic boolean isCreateJournalDir()
ActiveMQServerControlisCreateJournalDir in interface ActiveMQServerControlpublic boolean isJournalSyncNonTransactional()
ActiveMQServerControlisJournalSyncNonTransactional in interface ActiveMQServerControlpublic boolean isJournalSyncTransactional()
ActiveMQServerControlisJournalSyncTransactional in interface ActiveMQServerControlpublic boolean isSecurityEnabled()
ActiveMQServerControlisSecurityEnabled in interface ActiveMQServerControlpublic boolean isAsyncConnectionExecutionEnabled()
ActiveMQServerControlisAsyncConnectionExecutionEnabled in interface ActiveMQServerControlpublic int getDiskScanPeriod()
ActiveMQServerControlgetDiskScanPeriod in interface ActiveMQServerControlpublic int getMaxDiskUsage()
ActiveMQServerControlgetMaxDiskUsage in interface ActiveMQServerControlpublic long getGlobalMaxSize()
ActiveMQServerControlgetGlobalMaxSize in interface ActiveMQServerControlpublic void deployQueue(String address, String name, String filterString) throws Exception
ActiveMQServerControladdress is null it will be defaulted to name.
deployQueue in interface ActiveMQServerControladdress - address to bind the queue toname - name of the queuefilterString - of the queueExceptionpublic void deployQueue(String address, String name, String filterStr, boolean durable) throws Exception
ActiveMQServerControladdress is null it will be defaulted to name.
deployQueue in interface ActiveMQServerControladdress - address to bind the queue toname - name of the queuefilterStr - of the queuedurable - whether the queue is durableExceptionpublic void createQueue(String address, String name) throws Exception
ActiveMQServerControladdress is null it will be defaulted to name.
ActiveMQQueueExistsException) exception if the queue already exits.createQueue in interface ActiveMQServerControladdress - address to bind the queue toname - name of the queueExceptionpublic void createQueue(String address, String name, boolean durable) throws Exception
ActiveMQServerControladdress is null it will be defaulted to name.
ActiveMQQueueExistsException) exception if the queue already exits.createQueue in interface ActiveMQServerControladdress - address to bind the queue toname - name of the queuedurable - whether the queue is durableExceptionpublic void createQueue(String address, String name, String filterStr, boolean durable) throws Exception
ActiveMQServerControladdress is null it will be defaulted to name.
ActiveMQQueueExistsException) exception if the queue already exits.createQueue in interface ActiveMQServerControladdress - address to bind the queue toname - name of the queuefilterStr - of the queuedurable - whether the queue is durableExceptionpublic String[] getQueueNames()
ActiveMQServerControlgetQueueNames in interface ActiveMQServerControlpublic String getUptime()
ActiveMQServerControlgetUptime in interface ActiveMQServerControlpublic long getUptimeMillis()
ActiveMQServerControlgetUptimeMillis in interface ActiveMQServerControlpublic boolean isReplicaSync()
ActiveMQServerControlisReplicaSync in interface ActiveMQServerControlpublic String[] getAddressNames()
ActiveMQServerControlgetAddressNames in interface ActiveMQServerControlpublic void destroyQueue(String name, boolean removeConsumers) throws Exception
ActiveMQServerControldestroyQueue in interface ActiveMQServerControlExceptionpublic void destroyQueue(String name) throws Exception
ActiveMQServerControldestroyQueue in interface ActiveMQServerControlExceptionpublic int getConnectionCount()
ActiveMQServerControlgetConnectionCount in interface ActiveMQServerControlpublic long getTotalConnectionCount()
ActiveMQServerControlgetTotalConnectionCount in interface ActiveMQServerControlpublic long getTotalMessageCount()
ActiveMQServerControlgetTotalMessageCount in interface ActiveMQServerControlpublic long getTotalMessagesAdded()
ActiveMQServerControlgetTotalMessagesAdded in interface ActiveMQServerControlpublic long getTotalMessagesAcknowledged()
ActiveMQServerControlgetTotalMessagesAcknowledged in interface ActiveMQServerControlpublic long getTotalConsumerCount()
ActiveMQServerControlgetTotalConsumerCount in interface ActiveMQServerControlpublic void enableMessageCounters()
ActiveMQServerControlenableMessageCounters in interface ActiveMQServerControlpublic void disableMessageCounters()
ActiveMQServerControldisableMessageCounters in interface ActiveMQServerControlpublic void resetAllMessageCounters()
ActiveMQServerControlresetAllMessageCounters in interface ActiveMQServerControlpublic void resetAllMessageCounterHistories()
ActiveMQServerControlresetAllMessageCounterHistories in interface ActiveMQServerControlpublic boolean isMessageCounterEnabled()
ActiveMQServerControlisMessageCounterEnabled in interface ActiveMQServerControlpublic long getMessageCounterSamplePeriod()
ActiveMQServerControlgetMessageCounterSamplePeriod in interface ActiveMQServerControlpublic void setMessageCounterSamplePeriod(long newPeriod)
ActiveMQServerControlsetMessageCounterSamplePeriod in interface ActiveMQServerControlnewPeriod - value must be greater than 1000mspublic int getMessageCounterMaxDayCount()
ActiveMQServerControlgetMessageCounterMaxDayCount in interface ActiveMQServerControlpublic void setMessageCounterMaxDayCount(int count)
ActiveMQServerControlsetMessageCounterMaxDayCount in interface ActiveMQServerControlcount - value must be greater than 0public String[] listPreparedTransactions()
ActiveMQServerControllistPreparedTransactions in interface ActiveMQServerControlActiveMQServerControl.commitPreparedTransaction(String),
ActiveMQServerControl.rollbackPreparedTransaction(String)public String listPreparedTransactionDetailsAsJSON() throws Exception
ActiveMQServerControllistPreparedTransactionDetailsAsJSON in interface ActiveMQServerControlExceptionpublic String listPreparedTransactionDetailsAsHTML() throws Exception
ActiveMQServerControllistPreparedTransactionDetailsAsHTML in interface ActiveMQServerControlExceptionpublic String[] listHeuristicCommittedTransactions()
ActiveMQServerControllistHeuristicCommittedTransactions in interface ActiveMQServerControlpublic String[] listHeuristicRolledBackTransactions()
ActiveMQServerControllistHeuristicRolledBackTransactions in interface ActiveMQServerControlpublic boolean commitPreparedTransaction(String transactionAsBase64) throws Exception
ActiveMQServerControlcommitPreparedTransaction in interface ActiveMQServerControltransactionAsBase64 - base 64 representation of a prepare transactiontrue if the transaction was successfully committed, false elseExceptionActiveMQServerControl.listPreparedTransactions()public boolean rollbackPreparedTransaction(String transactionAsBase64) throws Exception
ActiveMQServerControlrollbackPreparedTransaction in interface ActiveMQServerControltransactionAsBase64 - base 64 representation of a prepare transactiontrue if the transaction was successfully rolled back, false elseExceptionActiveMQServerControl.listPreparedTransactions()public String[] listRemoteAddresses()
ActiveMQServerControllistRemoteAddresses in interface ActiveMQServerControlpublic String[] listRemoteAddresses(String ipAddress)
ActiveMQServerControllistRemoteAddresses in interface ActiveMQServerControlpublic boolean closeConnectionsForAddress(String ipAddress)
ActiveMQServerControlcloseConnectionsForAddress in interface ActiveMQServerControlpublic boolean closeConsumerConnectionsForAddress(String address)
ActiveMQServerControlcloseConsumerConnectionsForAddress in interface ActiveMQServerControlpublic boolean closeConnectionsForUser(String userName)
ActiveMQServerControlcloseConnectionsForUser in interface ActiveMQServerControlpublic String[] listConnectionIDs()
ActiveMQServerControllistConnectionIDs in interface ActiveMQServerControlpublic String[] listSessions(String connectionID)
ActiveMQServerControllistSessions in interface ActiveMQServerControlpublic String listProducersInfoAsJSON() throws Exception
listProducersInfoAsJSON in interface ActiveMQServerControlExceptionpublic String listConnectionsAsJSON() throws Exception
ActiveMQServerControl
[
{
"creationTime": 1469240429671,
"sessionCount": 1,
"implementation": "RemotingConnectionImpl",
"connectionID": "1648309901",
"clientAddress": "\/127.0.0.1:57649"
}
]
listConnectionsAsJSON in interface ActiveMQServerControlExceptionpublic String listSessionsAsJSON(String connectionID) throws Exception
ActiveMQServerControl
[
{
"principal": "myUser",
"creationTime": 1469240773157,
"consumerCount": 0,
"sessionID": "d33d10db-507c-11e6-9e47-e8b1fc439540"
}
]
listSessionsAsJSON in interface ActiveMQServerControlExceptionpublic String listConsumersAsJSON(String connectionID) throws Exception
ActiveMQServerControl
[
{
"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"
}
]
listConsumersAsJSON in interface ActiveMQServerControlExceptionpublic String listAllConsumersAsJSON() throws Exception
ActiveMQServerControl
[
{
"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"
}
]
listAllConsumersAsJSON in interface ActiveMQServerControlExceptionpublic Object[] getConnectors() throws Exception
ActiveMQServerControlgetConnectors in interface ActiveMQServerControlExceptionpublic String getConnectorsAsJSON() throws Exception
ActiveMQServerControlgetConnectorsAsJSON in interface ActiveMQServerControlExceptionpublic void addSecuritySettings(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles) throws Exception
addSecuritySettings in interface ActiveMQServerControlExceptionpublic void addSecuritySettings(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles, String browseRoles) throws Exception
addSecuritySettings in interface ActiveMQServerControlExceptionpublic void removeSecuritySettings(String addressMatch) throws Exception
removeSecuritySettings in interface ActiveMQServerControlExceptionpublic Object[] getRoles(String addressMatch) throws Exception
getRoles in interface ActiveMQServerControlExceptionpublic String getRolesAsJSON(String addressMatch) throws Exception
getRolesAsJSON in interface ActiveMQServerControlExceptionpublic String getAddressSettingsAsJSON(String address) throws Exception
ActiveMQServerControlgetAddressSettingsAsJSON in interface ActiveMQServerControlExceptionpublic void addAddressSettings(String address, 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
ActiveMQServerControladdAddressSettings in interface ActiveMQServerControlExceptionpublic void removeAddressSettings(String addressMatch) throws Exception
removeAddressSettings in interface ActiveMQServerControlExceptionpublic void sendQueueInfoToQueue(String queueName, String address) throws Exception
ActiveMQServerControlsendQueueInfoToQueue in interface ActiveMQServerControlExceptionpublic String[] getDivertNames()
getDivertNames in interface ActiveMQServerControlpublic void createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName) throws Exception
createDivert in interface ActiveMQServerControlExceptionpublic void destroyDivert(String name) throws Exception
destroyDivert in interface ActiveMQServerControlExceptionpublic String[] getBridgeNames()
getBridgeNames in interface ActiveMQServerControlpublic 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 staticConnectorsOrDiscoveryGroup, boolean useDiscoveryGroup, boolean ha, String user, String password) throws Exception
createBridge in interface ActiveMQServerControlExceptionpublic 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 staticConnectorsOrDiscoveryGroup, boolean useDiscoveryGroup, boolean ha, String user, String password) throws Exception
createBridge in interface ActiveMQServerControlExceptionpublic void destroyBridge(String name) throws Exception
destroyBridge in interface ActiveMQServerControlExceptionpublic void createConnectorService(String name, String factoryClass, Map<String,Object> parameters) throws Exception
createConnectorService in interface ActiveMQServerControlExceptionpublic void destroyConnectorService(String name) throws Exception
destroyConnectorService in interface ActiveMQServerControlExceptionpublic String[] getConnectorServices()
getConnectorServices in interface ActiveMQServerControlpublic void forceFailover()
throws Exception
forceFailover in interface ActiveMQServerControlExceptionpublic void updateDuplicateIdCache(String address, Object[] ids) throws Exception
updateDuplicateIdCache in interface ActiveMQServerControlExceptionpublic void scaleDown(String connector) throws Exception
scaleDown in interface ActiveMQServerControlExceptionpublic void removeNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws ListenerNotFoundException
removeNotificationListener in interface NotificationEmitterListenerNotFoundExceptionpublic void removeNotificationListener(NotificationListener listener) throws ListenerNotFoundException
removeNotificationListener in interface NotificationBroadcasterListenerNotFoundExceptionpublic void addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws IllegalArgumentException
addNotificationListener in interface NotificationBroadcasterIllegalArgumentExceptionpublic MBeanNotificationInfo[] getNotificationInfo()
getNotificationInfo in interface NotificationBroadcasterpublic long getConnectionTTLOverride()
ActiveMQServerControlgetConnectionTTLOverride in interface ActiveMQServerControlpublic int getIDCacheSize()
ActiveMQServerControlgetIDCacheSize in interface ActiveMQServerControlpublic String getLargeMessagesDirectory()
ActiveMQServerControlgetLargeMessagesDirectory in interface ActiveMQServerControlpublic String getManagementAddress()
ActiveMQServerControlgetManagementAddress in interface ActiveMQServerControlpublic String getManagementNotificationAddress()
ActiveMQServerControlgetManagementNotificationAddress in interface ActiveMQServerControlpublic long getMessageExpiryScanPeriod()
ActiveMQServerControlgetMessageExpiryScanPeriod in interface ActiveMQServerControlpublic long getMessageExpiryThreadPriority()
ActiveMQServerControlgetMessageExpiryThreadPriority in interface ActiveMQServerControlpublic long getTransactionTimeout()
ActiveMQServerControlgetTransactionTimeout in interface ActiveMQServerControlpublic long getTransactionTimeoutScanPeriod()
ActiveMQServerControlgetTransactionTimeoutScanPeriod in interface ActiveMQServerControlpublic boolean isPersistDeliveryCountBeforeDelivery()
ActiveMQServerControlisPersistDeliveryCountBeforeDelivery in interface ActiveMQServerControlpublic boolean isPersistIDCache()
ActiveMQServerControlisPersistIDCache in interface ActiveMQServerControlpublic boolean isWildcardRoutingEnabled()
ActiveMQServerControlisWildcardRoutingEnabled in interface ActiveMQServerControlprotected MBeanOperationInfo[] fillMBeanOperationInfo()
fillMBeanOperationInfo in class AbstractControlprotected MBeanAttributeInfo[] fillMBeanAttributeInfo()
fillMBeanAttributeInfo in class AbstractControlpublic void onNotification(Notification notification)
onNotification in interface NotificationListenerCopyright © 2018 JBoss by Red Hat. All rights reserved.