public class ActiveMQServerControlImpl extends AbstractControl implements ActiveMQServerControl, NotificationEmitter, NotificationListener
Modifier and Type | Class and Description |
---|---|
static class |
ActiveMQServerControlImpl.QueueTextFormatter |
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 |
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,
boolean autoCreateQueues,
boolean autoDeleteQueues,
boolean autoCreateAddresses,
boolean autoDeleteAddresses)
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) |
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 |
buildSessionJSON(JsonArrayBuilder array,
ServerSession sess) |
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 |
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 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 |
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 staticConnectorsOrDiscoveryGroup,
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 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 |
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) |
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,
boolean durable,
String routingType)
Create a queue.
|
void |
createQueue(String address,
String name,
String routingType)
Create a durable queue.
|
void |
createQueue(String address,
String name,
String filterStr,
boolean durable)
Create a queue.
|
void |
createQueue(String address,
String name,
String filterStr,
boolean durable,
String routingType)
Create a queue.
|
String |
createQueue(String address,
String routingType,
String name,
String filterStr,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreateAddress)
Create a queue.
|
void |
deleteAddress(String name) |
void |
deleteAddress(String name,
boolean force) |
void |
deployQueue(String address,
String name,
String filterString)
Deprecated.
|
void |
deployQueue(String address,
String name,
String filterStr,
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.
|
protected MBeanAttributeInfo[] |
fillMBeanAttributeInfo() |
protected MBeanOperationInfo[] |
fillMBeanOperationInfo() |
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 global maximum limit
|
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.
|
String |
getNodeID()
Returns the node ID of this server.
|
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.
|
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 |
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[] |
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.
|
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 |
listPreparedTransactionDetailsAsHTML(TransactionDetailFactory factory) |
String |
listPreparedTransactionDetailsAsJSON()
List all the prepared transaction, sorted by date,
oldest first, with details, in text format.
|
String |
listPreparedTransactionDetailsAsJSON(TransactionDetailFactory factory) |
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[] |
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) |
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.
|
String |
updateAddress(String name,
String routingTypes) |
void |
updateDuplicateIdCache(String address,
Object[] ids) |
String |
updateQueue(String name,
String routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers)
Update a queue.
|
String |
updateQueue(String name,
String routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive)
Update a queue.
|
blockOnIO, clearIO, getMBeanInfo
cacheMBeanInfo, 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, setImplementation
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
listDivertNames
public ActiveMQServerControlImpl(PostOffice postOffice, Configuration configuration, ResourceManager resourceManager, RemotingService remotingService, ActiveMQServer messagingServer, MessageCounterManager messageCounterManager, StorageManager storageManager, NotificationBroadcasterSupport broadcaster) throws Exception
Exception
public boolean isStarted()
ActiveMQServerControl
isStarted
in interface ActiveMQServerControl
public String getVersion()
ActiveMQServerControl
getVersion
in interface ActiveMQServerControl
public boolean isBackup()
ActiveMQServerControl
true
if this server is a backup, false
if it is a live server.
false
.isBackup
in interface ActiveMQServerControl
public boolean isSharedStore()
ActiveMQServerControl
isSharedStore
in interface ActiveMQServerControl
public String getBindingsDirectory()
ActiveMQServerControl
getBindingsDirectory
in interface ActiveMQServerControl
public String[] getInterceptorClassNames()
public String[] getIncomingInterceptorClassNames()
ActiveMQServerControl
getIncomingInterceptorClassNames
in interface ActiveMQServerControl
Interceptor
public String[] getOutgoingInterceptorClassNames()
ActiveMQServerControl
getOutgoingInterceptorClassNames
in interface ActiveMQServerControl
Interceptor
public int getJournalBufferSize()
ActiveMQServerControl
getJournalBufferSize
in interface ActiveMQServerControl
public int getJournalBufferTimeout()
ActiveMQServerControl
getJournalBufferTimeout
in interface ActiveMQServerControl
public void setFailoverOnServerShutdown(boolean failoverOnServerShutdown)
ActiveMQServerControl
setFailoverOnServerShutdown
in interface ActiveMQServerControl
public boolean isFailoverOnServerShutdown()
ActiveMQServerControl
isFailoverOnServerShutdown
in interface ActiveMQServerControl
public int getJournalMaxIO()
ActiveMQServerControl
getJournalMaxIO
in interface ActiveMQServerControl
public String getJournalDirectory()
ActiveMQServerControl
getJournalDirectory
in interface ActiveMQServerControl
public int getJournalFileSize()
ActiveMQServerControl
getJournalFileSize
in interface ActiveMQServerControl
public int getJournalMinFiles()
ActiveMQServerControl
getJournalMinFiles
in interface ActiveMQServerControl
public int getJournalCompactMinFiles()
ActiveMQServerControl
getJournalCompactMinFiles
in interface ActiveMQServerControl
public int getJournalCompactPercentage()
ActiveMQServerControl
getJournalCompactPercentage
in interface ActiveMQServerControl
public boolean isPersistenceEnabled()
ActiveMQServerControl
isPersistenceEnabled
in interface ActiveMQServerControl
public String getJournalType()
ActiveMQServerControl
NIO
or ASYNCIO
).getJournalType
in interface ActiveMQServerControl
public String getPagingDirectory()
ActiveMQServerControl
getPagingDirectory
in interface ActiveMQServerControl
public int getScheduledThreadPoolMaxSize()
ActiveMQServerControl
getScheduledThreadPoolMaxSize
in interface ActiveMQServerControl
public int getThreadPoolMaxSize()
ActiveMQServerControl
getThreadPoolMaxSize
in interface ActiveMQServerControl
public long getSecurityInvalidationInterval()
ActiveMQServerControl
getSecurityInvalidationInterval
in interface ActiveMQServerControl
public boolean isClustered()
ActiveMQServerControl
isClustered
in interface ActiveMQServerControl
public boolean isCreateBindingsDir()
ActiveMQServerControl
isCreateBindingsDir
in interface ActiveMQServerControl
public boolean isCreateJournalDir()
ActiveMQServerControl
isCreateJournalDir
in interface ActiveMQServerControl
public boolean isJournalSyncNonTransactional()
ActiveMQServerControl
isJournalSyncNonTransactional
in interface ActiveMQServerControl
public boolean isJournalSyncTransactional()
ActiveMQServerControl
isJournalSyncTransactional
in interface ActiveMQServerControl
public boolean isSecurityEnabled()
ActiveMQServerControl
isSecurityEnabled
in interface ActiveMQServerControl
public boolean isAsyncConnectionExecutionEnabled()
ActiveMQServerControl
isAsyncConnectionExecutionEnabled
in interface ActiveMQServerControl
public int getDiskScanPeriod()
ActiveMQServerControl
getDiskScanPeriod
in interface ActiveMQServerControl
public int getMaxDiskUsage()
ActiveMQServerControl
getMaxDiskUsage
in interface ActiveMQServerControl
public long getGlobalMaxSize()
ActiveMQServerControl
getGlobalMaxSize
in interface ActiveMQServerControl
public long getAddressMemoryUsage()
ActiveMQServerControl
getAddressMemoryUsage
in interface ActiveMQServerControl
public int getAddressMemoryUsagePercentage()
ActiveMQServerControl
getAddressMemoryUsagePercentage
in interface ActiveMQServerControl
public boolean freezeReplication()
freezeReplication
in interface ActiveMQServerControl
public String createAddress(String name, String routingTypes) throws Exception
createAddress
in interface ActiveMQServerControl
Exception
public String updateAddress(String name, String routingTypes) throws Exception
updateAddress
in interface ActiveMQServerControl
Exception
public void deleteAddress(String name) throws Exception
deleteAddress
in interface ActiveMQServerControl
Exception
public void deleteAddress(String name, boolean force) throws Exception
deleteAddress
in interface ActiveMQServerControl
Exception
@Deprecated public void deployQueue(String address, String name, String filterString) throws Exception
ActiveMQServerControl
address
is null
it will be defaulted to name
.
deployQueue
in interface ActiveMQServerControl
address
- address to bind the queue toname
- name of the queuefilterString
- of the queueException
@Deprecated public void deployQueue(String address, String name, String filterStr, boolean durable) throws Exception
ActiveMQServerControl
address
is null
it will be defaulted to name
.
deployQueue
in interface ActiveMQServerControl
address
- address to bind the queue toname
- name of the queuefilterStr
- of the queuedurable
- whether the queue is durableException
public void createQueue(String address, String name) throws Exception
ActiveMQServerControl
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.createQueue
in interface ActiveMQServerControl
address
- address to bind the queue toname
- name of the queueException
public void createQueue(String address, String name, String routingType) throws Exception
ActiveMQServerControl
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.createQueue
in interface ActiveMQServerControl
address
- address to bind the queue toname
- name of the queueroutingType
- The routing type used for this address, MULTICAST or ANYCASTException
public void createQueue(String address, String name, boolean durable) throws Exception
ActiveMQServerControl
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.createQueue
in interface ActiveMQServerControl
address
- address to bind the queue toname
- name of the queuedurable
- whether the queue is durableException
public void createQueue(String address, String name, boolean durable, String routingType) throws Exception
ActiveMQServerControl
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.createQueue
in interface ActiveMQServerControl
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
public void createQueue(String address, String name, String filterStr, boolean durable) throws Exception
ActiveMQServerControl
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.createQueue
in interface ActiveMQServerControl
address
- address to bind the queue toname
- name of the queuefilterStr
- of the queuedurable
- whether the queue is durableException
public void createQueue(String address, String name, String filterStr, boolean durable, String routingType) throws Exception
ActiveMQServerControl
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.createQueue
in interface ActiveMQServerControl
address
- address to bind the queue toname
- name of the queuefilterStr
- of the queuedurable
- whether the queue is durableroutingType
- The routing type used for this address, MULTICAST or ANYCASTException
public String createQueue(String address, String routingType, String name, String filterStr, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress) throws Exception
ActiveMQServerControl
address
is null
it will be defaulted to name
.
ActiveMQQueueExistsException
) exception if the queue already exits.createQueue
in interface ActiveMQServerControl
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
public String updateQueue(String name, String routingType, Integer maxConsumers, Boolean purgeOnNoConsumers) throws Exception
ActiveMQServerControl
updateQueue
in interface ActiveMQServerControl
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
public String updateQueue(String name, String routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive) throws Exception
ActiveMQServerControl
updateQueue
in interface ActiveMQServerControl
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
public String[] getQueueNames()
ActiveMQServerControl
getQueueNames
in interface ActiveMQServerControl
public String[] getQueueNames(String routingType)
ActiveMQServerControl
getQueueNames
in interface ActiveMQServerControl
public String getUptime()
ActiveMQServerControl
getUptime
in interface ActiveMQServerControl
public long getUptimeMillis()
ActiveMQServerControl
getUptimeMillis
in interface ActiveMQServerControl
public boolean isReplicaSync()
ActiveMQServerControl
isReplicaSync
in interface ActiveMQServerControl
public String[] getAddressNames()
ActiveMQServerControl
getAddressNames
in interface ActiveMQServerControl
public void destroyQueue(String name, boolean removeConsumers, boolean autoDeleteAddress) throws Exception
ActiveMQServerControl
destroyQueue
in interface ActiveMQServerControl
Exception
public void destroyQueue(String name, boolean removeConsumers) throws Exception
ActiveMQServerControl
destroyQueue
in interface ActiveMQServerControl
Exception
public void destroyQueue(String name) throws Exception
ActiveMQServerControl
destroyQueue
in interface ActiveMQServerControl
Exception
public String getAddressInfo(String address) throws ActiveMQAddressDoesNotExistException
getAddressInfo
in interface ActiveMQServerControl
ActiveMQAddressDoesNotExistException
public String listBindingsForAddress(String address) throws Exception
listBindingsForAddress
in interface ActiveMQServerControl
Exception
public String listAddresses(String separator) throws Exception
listAddresses
in interface ActiveMQServerControl
Exception
public int getConnectionCount()
ActiveMQServerControl
getConnectionCount
in interface ActiveMQServerControl
public long getTotalConnectionCount()
ActiveMQServerControl
getTotalConnectionCount
in interface ActiveMQServerControl
public long getTotalMessageCount()
ActiveMQServerControl
getTotalMessageCount
in interface ActiveMQServerControl
public long getTotalMessagesAdded()
ActiveMQServerControl
getTotalMessagesAdded
in interface ActiveMQServerControl
public long getTotalMessagesAcknowledged()
ActiveMQServerControl
getTotalMessagesAcknowledged
in interface ActiveMQServerControl
public long getTotalConsumerCount()
ActiveMQServerControl
getTotalConsumerCount
in interface ActiveMQServerControl
public void enableMessageCounters()
ActiveMQServerControl
enableMessageCounters
in interface ActiveMQServerControl
public void disableMessageCounters()
ActiveMQServerControl
disableMessageCounters
in interface ActiveMQServerControl
public void resetAllMessageCounters()
ActiveMQServerControl
resetAllMessageCounters
in interface ActiveMQServerControl
public void resetAllMessageCounterHistories()
ActiveMQServerControl
resetAllMessageCounterHistories
in interface ActiveMQServerControl
public boolean isMessageCounterEnabled()
ActiveMQServerControl
isMessageCounterEnabled
in interface ActiveMQServerControl
public long getMessageCounterSamplePeriod()
ActiveMQServerControl
getMessageCounterSamplePeriod
in interface ActiveMQServerControl
public void setMessageCounterSamplePeriod(long newPeriod)
ActiveMQServerControl
setMessageCounterSamplePeriod
in interface ActiveMQServerControl
newPeriod
- value must be greater than 1000mspublic int getMessageCounterMaxDayCount()
ActiveMQServerControl
getMessageCounterMaxDayCount
in interface ActiveMQServerControl
public void setMessageCounterMaxDayCount(int count)
ActiveMQServerControl
setMessageCounterMaxDayCount
in interface ActiveMQServerControl
count
- value must be greater than 0public String[] listPreparedTransactions()
ActiveMQServerControl
listPreparedTransactions
in interface ActiveMQServerControl
ActiveMQServerControl.commitPreparedTransaction(String)
,
ActiveMQServerControl.rollbackPreparedTransaction(String)
public String listPreparedTransactionDetailsAsJSON() throws Exception
ActiveMQServerControl
listPreparedTransactionDetailsAsJSON
in interface ActiveMQServerControl
Exception
public String listPreparedTransactionDetailsAsJSON(TransactionDetailFactory factory) throws Exception
Exception
public String listPreparedTransactionDetailsAsHTML() throws Exception
ActiveMQServerControl
listPreparedTransactionDetailsAsHTML
in interface ActiveMQServerControl
Exception
public String listPreparedTransactionDetailsAsHTML(TransactionDetailFactory factory) throws Exception
Exception
public String[] listHeuristicCommittedTransactions()
ActiveMQServerControl
listHeuristicCommittedTransactions
in interface ActiveMQServerControl
public String[] listHeuristicRolledBackTransactions()
ActiveMQServerControl
listHeuristicRolledBackTransactions
in interface ActiveMQServerControl
public boolean commitPreparedTransaction(String transactionAsBase64) throws Exception
ActiveMQServerControl
commitPreparedTransaction
in interface ActiveMQServerControl
transactionAsBase64
- base 64 representation of a prepare transactiontrue
if the transaction was successfully committed, false
elseException
ActiveMQServerControl.listPreparedTransactions()
public boolean rollbackPreparedTransaction(String transactionAsBase64) throws Exception
ActiveMQServerControl
rollbackPreparedTransaction
in interface ActiveMQServerControl
transactionAsBase64
- base 64 representation of a prepare transactiontrue
if the transaction was successfully rolled back, false
elseException
ActiveMQServerControl.listPreparedTransactions()
public String[] listRemoteAddresses()
ActiveMQServerControl
listRemoteAddresses
in interface ActiveMQServerControl
public String[] listRemoteAddresses(String ipAddress)
ActiveMQServerControl
listRemoteAddresses
in interface ActiveMQServerControl
public boolean closeConnectionsForAddress(String ipAddress)
ActiveMQServerControl
closeConnectionsForAddress
in interface ActiveMQServerControl
public boolean closeConsumerConnectionsForAddress(String address)
ActiveMQServerControl
closeConsumerConnectionsForAddress
in interface ActiveMQServerControl
public boolean closeConnectionsForUser(String userName)
ActiveMQServerControl
closeConnectionsForUser
in interface ActiveMQServerControl
public boolean closeConnectionWithID(String ID)
ActiveMQServerControl
closeConnectionWithID
in interface ActiveMQServerControl
public boolean closeSessionWithID(String connectionID, String ID) throws Exception
ActiveMQServerControl
closeSessionWithID
in interface ActiveMQServerControl
Exception
public boolean closeConsumerWithID(String sessionID, String ID) throws Exception
ActiveMQServerControl
closeConsumerWithID
in interface ActiveMQServerControl
Exception
public String[] listConnectionIDs()
ActiveMQServerControl
listConnectionIDs
in interface ActiveMQServerControl
public String[] listSessions(String connectionID)
ActiveMQServerControl
listSessions
in interface ActiveMQServerControl
public String listProducersInfoAsJSON() throws Exception
listProducersInfoAsJSON
in interface ActiveMQServerControl
Exception
public String listConnections(String options, int page, int pageSize) throws Exception
listConnections
in interface ActiveMQServerControl
Exception
public String listSessions(String options, int page, int pageSize) throws Exception
listSessions
in interface ActiveMQServerControl
Exception
public String listConsumers(String options, int page, int pageSize) throws Exception
listConsumers
in interface ActiveMQServerControl
Exception
public String listAddresses(String options, int page, int pageSize) throws Exception
listAddresses
in interface ActiveMQServerControl
Exception
public String listQueues(String options, int page, int pageSize) throws Exception
listQueues
in interface ActiveMQServerControl
Exception
public String listProducers(String options, int page, int pageSize) throws Exception
listProducers
in interface ActiveMQServerControl
Exception
public String listConnectionsAsJSON() throws Exception
ActiveMQServerControl
[ { "creationTime": 1469240429671, "sessionCount": 1, "implementation": "RemotingConnectionImpl", "connectionID": "1648309901", "clientAddress": "\/127.0.0.1:57649" } ]
listConnectionsAsJSON
in interface ActiveMQServerControl
Exception
public String listSessionsAsJSON(String connectionID) throws Exception
ActiveMQServerControl
[ { "principal": "myUser", "creationTime": 1469240773157, "consumerCount": 0, "sessionID": "d33d10db-507c-11e6-9e47-e8b1fc439540" } ]
listSessionsAsJSON
in interface ActiveMQServerControl
Exception
public String listAllSessionsAsJSON() throws Exception
ActiveMQServerControl
[ { "sessionID":"e71d61d7-2176-11e8-9057-a0afbd82eaba", "creationTime":1520365520212, "consumerCount":1, "principal":"myUser" }, { "sessionID":"e718a6e6-2176-11e8-9057-a0afbd82eaba", "creationTime":1520365520191, "consumerCount":0, "principal":"guest" } ]
listAllSessionsAsJSON
in interface ActiveMQServerControl
Exception
public void buildSessionJSON(JsonArrayBuilder array, ServerSession sess)
public 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 ActiveMQServerControl
Exception
public 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 ActiveMQServerControl
Exception
public Object[] getConnectors() throws Exception
ActiveMQServerControl
getConnectors
in interface ActiveMQServerControl
Exception
public String getConnectorsAsJSON() throws Exception
ActiveMQServerControl
getConnectorsAsJSON
in interface ActiveMQServerControl
Exception
public void addSecuritySettings(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles) throws Exception
addSecuritySettings
in interface ActiveMQServerControl
Exception
public 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 ActiveMQServerControl
Exception
public 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
addSecuritySettings
in interface ActiveMQServerControl
Exception
public void removeSecuritySettings(String addressMatch) throws Exception
removeSecuritySettings
in interface ActiveMQServerControl
Exception
public Object[] getRoles(String addressMatch) throws Exception
getRoles
in interface ActiveMQServerControl
Exception
public String getRolesAsJSON(String addressMatch) throws Exception
getRolesAsJSON
in interface ActiveMQServerControl
Exception
public String getAddressSettingsAsJSON(String address) throws Exception
ActiveMQServerControl
getAddressSettingsAsJSON
in interface ActiveMQServerControl
Exception
public 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
ActiveMQServerControl
addAddressSettings
in interface ActiveMQServerControl
Exception
public 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, boolean autoCreateQueues, boolean autoDeleteQueues, boolean autoCreateAddresses, boolean autoDeleteAddresses) throws Exception
ActiveMQServerControl
addAddressSettings
in interface ActiveMQServerControl
Exception
public void removeAddressSettings(String addressMatch) throws Exception
removeAddressSettings
in interface ActiveMQServerControl
Exception
public void sendQueueInfoToQueue(String queueName, String address) throws Exception
Exception
public String[] getDivertNames()
getDivertNames
in interface ActiveMQServerControl
public void createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName) throws Exception
createDivert
in interface ActiveMQServerControl
Exception
public void createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName, String routingType) throws Exception
createDivert
in interface ActiveMQServerControl
Exception
public void createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName, String transformerPropertiesAsJSON, String routingType) throws Exception
createDivert
in interface ActiveMQServerControl
Exception
public void createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName, Map<String,String> transformerProperties, String routingType) throws Exception
createDivert
in interface ActiveMQServerControl
Exception
public void destroyDivert(String name) throws Exception
destroyDivert
in interface ActiveMQServerControl
Exception
public String[] getBridgeNames()
getBridgeNames
in interface ActiveMQServerControl
public 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 ActiveMQServerControl
Exception
public 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 staticConnectorsOrDiscoveryGroup, boolean useDiscoveryGroup, boolean ha, String user, String password) throws Exception
createBridge
in interface ActiveMQServerControl
Exception
public 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 staticConnectorsOrDiscoveryGroup, boolean useDiscoveryGroup, boolean ha, String user, String password) throws Exception
createBridge
in interface ActiveMQServerControl
Exception
public 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 ActiveMQServerControl
Exception
public void destroyBridge(String name) throws Exception
destroyBridge
in interface ActiveMQServerControl
Exception
public void createConnectorService(String name, String factoryClass, Map<String,Object> parameters) throws Exception
createConnectorService
in interface ActiveMQServerControl
Exception
public void destroyConnectorService(String name) throws Exception
destroyConnectorService
in interface ActiveMQServerControl
Exception
public String[] getConnectorServices()
getConnectorServices
in interface ActiveMQServerControl
public void forceFailover() throws Exception
forceFailover
in interface ActiveMQServerControl
Exception
public void updateDuplicateIdCache(String address, Object[] ids) throws Exception
Exception
public void scaleDown(String connector) throws Exception
scaleDown
in interface ActiveMQServerControl
Exception
public String listNetworkTopology() throws Exception
listNetworkTopology
in interface ActiveMQServerControl
Exception
public void removeNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws ListenerNotFoundException
removeNotificationListener
in interface NotificationEmitter
ListenerNotFoundException
public void removeNotificationListener(NotificationListener listener) throws ListenerNotFoundException
removeNotificationListener
in interface NotificationBroadcaster
ListenerNotFoundException
public void addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws IllegalArgumentException
addNotificationListener
in interface NotificationBroadcaster
IllegalArgumentException
public MBeanNotificationInfo[] getNotificationInfo()
getNotificationInfo
in interface NotificationBroadcaster
public long getConnectionTTLOverride()
ActiveMQServerControl
getConnectionTTLOverride
in interface ActiveMQServerControl
public int getIDCacheSize()
ActiveMQServerControl
getIDCacheSize
in interface ActiveMQServerControl
public String getLargeMessagesDirectory()
ActiveMQServerControl
getLargeMessagesDirectory
in interface ActiveMQServerControl
public String getManagementAddress()
ActiveMQServerControl
getManagementAddress
in interface ActiveMQServerControl
public String getNodeID()
ActiveMQServerControl
getNodeID
in interface ActiveMQServerControl
public String getManagementNotificationAddress()
ActiveMQServerControl
getManagementNotificationAddress
in interface ActiveMQServerControl
public long getMessageExpiryScanPeriod()
ActiveMQServerControl
getMessageExpiryScanPeriod
in interface ActiveMQServerControl
public long getMessageExpiryThreadPriority()
ActiveMQServerControl
getMessageExpiryThreadPriority
in interface ActiveMQServerControl
public long getTransactionTimeout()
ActiveMQServerControl
getTransactionTimeout
in interface ActiveMQServerControl
public long getTransactionTimeoutScanPeriod()
ActiveMQServerControl
getTransactionTimeoutScanPeriod
in interface ActiveMQServerControl
public boolean isPersistDeliveryCountBeforeDelivery()
ActiveMQServerControl
isPersistDeliveryCountBeforeDelivery
in interface ActiveMQServerControl
public boolean isPersistIDCache()
ActiveMQServerControl
isPersistIDCache
in interface ActiveMQServerControl
public boolean isWildcardRoutingEnabled()
ActiveMQServerControl
isWildcardRoutingEnabled
in interface ActiveMQServerControl
protected MBeanOperationInfo[] fillMBeanOperationInfo()
fillMBeanOperationInfo
in class AbstractControl
protected MBeanAttributeInfo[] fillMBeanAttributeInfo()
fillMBeanAttributeInfo
in class AbstractControl
public void onNotification(Notification notification)
onNotification
in interface NotificationListener
Copyright © 2018 JBoss by Red Hat. All rights reserved.