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) |
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
public ActiveMQServerControlImpl(PostOffice postOffice, Configuration configuration, ResourceManager resourceManager, RemotingService remotingService, ActiveMQServer messagingServer, MessageCounterManager messageCounterManager, StorageManager storageManager, NotificationBroadcasterSupport broadcaster) throws Exception
Exception
public boolean isStarted()
isStarted
in interface ActiveMQServerControl
public String getVersion()
getVersion
in interface ActiveMQServerControl
public boolean isBackup()
isBackup
in interface ActiveMQServerControl
public boolean isSharedStore()
isSharedStore
in interface ActiveMQServerControl
public String getBindingsDirectory()
getBindingsDirectory
in interface ActiveMQServerControl
public String[] getInterceptorClassNames()
public String[] getIncomingInterceptorClassNames()
getIncomingInterceptorClassNames
in interface ActiveMQServerControl
public String[] getOutgoingInterceptorClassNames()
getOutgoingInterceptorClassNames
in interface ActiveMQServerControl
public int getJournalBufferSize()
getJournalBufferSize
in interface ActiveMQServerControl
public int getJournalBufferTimeout()
getJournalBufferTimeout
in interface ActiveMQServerControl
public void setFailoverOnServerShutdown(boolean failoverOnServerShutdown)
setFailoverOnServerShutdown
in interface ActiveMQServerControl
public boolean isFailoverOnServerShutdown()
isFailoverOnServerShutdown
in interface ActiveMQServerControl
public int getJournalMaxIO()
getJournalMaxIO
in interface ActiveMQServerControl
public String getJournalDirectory()
getJournalDirectory
in interface ActiveMQServerControl
public int getJournalFileSize()
getJournalFileSize
in interface ActiveMQServerControl
public int getJournalMinFiles()
getJournalMinFiles
in interface ActiveMQServerControl
public int getJournalCompactMinFiles()
getJournalCompactMinFiles
in interface ActiveMQServerControl
public int getJournalCompactPercentage()
getJournalCompactPercentage
in interface ActiveMQServerControl
public boolean isPersistenceEnabled()
isPersistenceEnabled
in interface ActiveMQServerControl
public String getJournalType()
getJournalType
in interface ActiveMQServerControl
public String getPagingDirectory()
getPagingDirectory
in interface ActiveMQServerControl
public int getScheduledThreadPoolMaxSize()
getScheduledThreadPoolMaxSize
in interface ActiveMQServerControl
public int getThreadPoolMaxSize()
getThreadPoolMaxSize
in interface ActiveMQServerControl
public long getSecurityInvalidationInterval()
getSecurityInvalidationInterval
in interface ActiveMQServerControl
public boolean isClustered()
isClustered
in interface ActiveMQServerControl
public boolean isCreateBindingsDir()
isCreateBindingsDir
in interface ActiveMQServerControl
public boolean isCreateJournalDir()
isCreateJournalDir
in interface ActiveMQServerControl
public boolean isJournalSyncNonTransactional()
isJournalSyncNonTransactional
in interface ActiveMQServerControl
public boolean isJournalSyncTransactional()
isJournalSyncTransactional
in interface ActiveMQServerControl
public boolean isSecurityEnabled()
isSecurityEnabled
in interface ActiveMQServerControl
public boolean isAsyncConnectionExecutionEnabled()
isAsyncConnectionExecutionEnabled
in interface ActiveMQServerControl
public int getDiskScanPeriod()
getDiskScanPeriod
in interface ActiveMQServerControl
public int getMaxDiskUsage()
getMaxDiskUsage
in interface ActiveMQServerControl
public long getGlobalMaxSize()
getGlobalMaxSize
in interface ActiveMQServerControl
public void deployQueue(String address, String name, String filterString) throws Exception
deployQueue
in interface ActiveMQServerControl
Exception
public void deployQueue(String address, String name, String filterStr, boolean durable) throws Exception
deployQueue
in interface ActiveMQServerControl
Exception
public void createQueue(String address, String name) throws Exception
createQueue
in interface ActiveMQServerControl
Exception
public void createQueue(String address, String name, boolean durable) throws Exception
createQueue
in interface ActiveMQServerControl
Exception
public void createQueue(String address, String name, String filterStr, boolean durable) throws Exception
createQueue
in interface ActiveMQServerControl
Exception
public String[] getQueueNames()
getQueueNames
in interface ActiveMQServerControl
public String getUptime()
getUptime
in interface ActiveMQServerControl
public long getUptimeMillis()
getUptimeMillis
in interface ActiveMQServerControl
public boolean isReplicaSync()
isReplicaSync
in interface ActiveMQServerControl
public String[] getAddressNames()
getAddressNames
in interface ActiveMQServerControl
public void destroyQueue(String name, boolean removeConsumers) throws Exception
destroyQueue
in interface ActiveMQServerControl
Exception
public void destroyQueue(String name) throws Exception
destroyQueue
in interface ActiveMQServerControl
Exception
public int getConnectionCount()
getConnectionCount
in interface ActiveMQServerControl
public long getTotalConnectionCount()
getTotalConnectionCount
in interface ActiveMQServerControl
public long getTotalMessageCount()
getTotalMessageCount
in interface ActiveMQServerControl
public long getTotalMessagesAdded()
getTotalMessagesAdded
in interface ActiveMQServerControl
public long getTotalMessagesAcknowledged()
getTotalMessagesAcknowledged
in interface ActiveMQServerControl
public long getTotalConsumerCount()
getTotalConsumerCount
in interface ActiveMQServerControl
public void enableMessageCounters()
enableMessageCounters
in interface ActiveMQServerControl
public void disableMessageCounters()
disableMessageCounters
in interface ActiveMQServerControl
public void resetAllMessageCounters()
resetAllMessageCounters
in interface ActiveMQServerControl
public void resetAllMessageCounterHistories()
resetAllMessageCounterHistories
in interface ActiveMQServerControl
public boolean isMessageCounterEnabled()
isMessageCounterEnabled
in interface ActiveMQServerControl
public long getMessageCounterSamplePeriod()
getMessageCounterSamplePeriod
in interface ActiveMQServerControl
public void setMessageCounterSamplePeriod(long newPeriod)
setMessageCounterSamplePeriod
in interface ActiveMQServerControl
public int getMessageCounterMaxDayCount()
getMessageCounterMaxDayCount
in interface ActiveMQServerControl
public void setMessageCounterMaxDayCount(int count)
setMessageCounterMaxDayCount
in interface ActiveMQServerControl
public String[] listPreparedTransactions()
listPreparedTransactions
in interface ActiveMQServerControl
public String listPreparedTransactionDetailsAsJSON() throws Exception
listPreparedTransactionDetailsAsJSON
in interface ActiveMQServerControl
Exception
public String listPreparedTransactionDetailsAsHTML() throws Exception
listPreparedTransactionDetailsAsHTML
in interface ActiveMQServerControl
Exception
public String[] listHeuristicCommittedTransactions()
listHeuristicCommittedTransactions
in interface ActiveMQServerControl
public String[] listHeuristicRolledBackTransactions()
listHeuristicRolledBackTransactions
in interface ActiveMQServerControl
public boolean commitPreparedTransaction(String transactionAsBase64) throws Exception
commitPreparedTransaction
in interface ActiveMQServerControl
Exception
public boolean rollbackPreparedTransaction(String transactionAsBase64) throws Exception
rollbackPreparedTransaction
in interface ActiveMQServerControl
Exception
public String[] listRemoteAddresses()
listRemoteAddresses
in interface ActiveMQServerControl
public String[] listRemoteAddresses(String ipAddress)
listRemoteAddresses
in interface ActiveMQServerControl
public boolean closeConnectionsForAddress(String ipAddress)
closeConnectionsForAddress
in interface ActiveMQServerControl
public boolean closeConsumerConnectionsForAddress(String address)
closeConsumerConnectionsForAddress
in interface ActiveMQServerControl
public boolean closeConnectionsForUser(String userName)
closeConnectionsForUser
in interface ActiveMQServerControl
public String[] listConnectionIDs()
listConnectionIDs
in interface ActiveMQServerControl
public String[] listSessions(String connectionID)
listSessions
in interface ActiveMQServerControl
public String listProducersInfoAsJSON() throws Exception
listProducersInfoAsJSON
in interface ActiveMQServerControl
Exception
public String listConnectionsAsJSON() throws Exception
listConnectionsAsJSON
in interface ActiveMQServerControl
Exception
public String listSessionsAsJSON(String connectionID) throws Exception
listSessionsAsJSON
in interface ActiveMQServerControl
Exception
public String listConsumersAsJSON(String connectionID) throws Exception
listConsumersAsJSON
in interface ActiveMQServerControl
Exception
public String listAllConsumersAsJSON() throws Exception
listAllConsumersAsJSON
in interface ActiveMQServerControl
Exception
public Object[] getConnectors() throws Exception
getConnectors
in interface ActiveMQServerControl
Exception
public String getConnectorsAsJSON() throws Exception
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 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
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
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
sendQueueInfoToQueue
in interface ActiveMQServerControl
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 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, 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
updateDuplicateIdCache
in interface ActiveMQServerControl
Exception
public void scaleDown(String connector) throws Exception
scaleDown
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()
getConnectionTTLOverride
in interface ActiveMQServerControl
public int getIDCacheSize()
getIDCacheSize
in interface ActiveMQServerControl
public String getLargeMessagesDirectory()
getLargeMessagesDirectory
in interface ActiveMQServerControl
public String getManagementAddress()
getManagementAddress
in interface ActiveMQServerControl
public String getManagementNotificationAddress()
getManagementNotificationAddress
in interface ActiveMQServerControl
public long getMessageExpiryScanPeriod()
getMessageExpiryScanPeriod
in interface ActiveMQServerControl
public long getMessageExpiryThreadPriority()
getMessageExpiryThreadPriority
in interface ActiveMQServerControl
public long getTransactionTimeout()
getTransactionTimeout
in interface ActiveMQServerControl
public long getTransactionTimeoutScanPeriod()
getTransactionTimeoutScanPeriod
in interface ActiveMQServerControl
public boolean isPersistDeliveryCountBeforeDelivery()
isPersistDeliveryCountBeforeDelivery
in interface ActiveMQServerControl
public boolean isPersistIDCache()
isPersistIDCache
in interface ActiveMQServerControl
public boolean isWildcardRoutingEnabled()
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 The Apache Software Foundation. All Rights Reserved.