public class ActiveMQServerControlImpl extends AbstractControl implements org.apache.activemq.artemis.api.core.management.ActiveMQServerControl, NotificationEmitter, org.apache.activemq.artemis.core.server.management.NotificationListener
storageManager| Constructor and Description |
|---|
ActiveMQServerControlImpl(PostOffice postOffice,
Configuration configuration,
ResourceManager resourceManager,
RemotingService remotingService,
ActiveMQServer messagingServer,
MessageCounterManager messageCounterManager,
StorageManager storageManager,
NotificationBroadcasterSupport broadcaster) |
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()
isStarted in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String getVersion()
getVersion in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isBackup()
isBackup in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isSharedStore()
isSharedStore in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String getBindingsDirectory()
getBindingsDirectory in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String[] getInterceptorClassNames()
public String[] getIncomingInterceptorClassNames()
getIncomingInterceptorClassNames in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String[] getOutgoingInterceptorClassNames()
getOutgoingInterceptorClassNames in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic int getJournalBufferSize()
getJournalBufferSize in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic int getJournalBufferTimeout()
getJournalBufferTimeout in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic void setFailoverOnServerShutdown(boolean failoverOnServerShutdown)
setFailoverOnServerShutdown in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isFailoverOnServerShutdown()
isFailoverOnServerShutdown in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic int getJournalMaxIO()
getJournalMaxIO in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String getJournalDirectory()
getJournalDirectory in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic int getJournalFileSize()
getJournalFileSize in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic int getJournalMinFiles()
getJournalMinFiles in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic int getJournalCompactMinFiles()
getJournalCompactMinFiles in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic int getJournalCompactPercentage()
getJournalCompactPercentage in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isPersistenceEnabled()
isPersistenceEnabled in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String getJournalType()
getJournalType in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String getPagingDirectory()
getPagingDirectory in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic int getScheduledThreadPoolMaxSize()
getScheduledThreadPoolMaxSize in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic int getThreadPoolMaxSize()
getThreadPoolMaxSize in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic long getSecurityInvalidationInterval()
getSecurityInvalidationInterval in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isClustered()
isClustered in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isCreateBindingsDir()
isCreateBindingsDir in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isCreateJournalDir()
isCreateJournalDir in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isJournalSyncNonTransactional()
isJournalSyncNonTransactional in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isJournalSyncTransactional()
isJournalSyncTransactional in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isSecurityEnabled()
isSecurityEnabled in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isAsyncConnectionExecutionEnabled()
isAsyncConnectionExecutionEnabled in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic int getDiskScanPeriod()
getDiskScanPeriod in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic int getMaxDiskUsage()
getMaxDiskUsage in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic long getGlobalMaxSize()
getGlobalMaxSize in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic void deployQueue(String address, String name, String filterString) throws Exception
deployQueue in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void deployQueue(String address, String name, String filterStr, boolean durable) throws Exception
deployQueue in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void createQueue(String address, String name) throws Exception
createQueue in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void createQueue(String address, String name, boolean durable) throws Exception
createQueue in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void createQueue(String address, String name, String filterStr, boolean durable) throws Exception
createQueue in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String[] getQueueNames()
getQueueNames in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String getUptime()
getUptime in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic long getUptimeMillis()
getUptimeMillis in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isReplicaSync()
isReplicaSync in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String[] getAddressNames()
getAddressNames in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic void destroyQueue(String name, boolean removeConsumers) throws Exception
destroyQueue in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void destroyQueue(String name) throws Exception
destroyQueue in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic int getConnectionCount()
getConnectionCount in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic long getTotalConnectionCount()
getTotalConnectionCount in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic long getTotalMessageCount()
getTotalMessageCount in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic long getTotalMessagesAdded()
getTotalMessagesAdded in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic long getTotalMessagesAcknowledged()
getTotalMessagesAcknowledged in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic long getTotalConsumerCount()
getTotalConsumerCount in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic void enableMessageCounters()
enableMessageCounters in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic void disableMessageCounters()
disableMessageCounters in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic void resetAllMessageCounters()
resetAllMessageCounters in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic void resetAllMessageCounterHistories()
resetAllMessageCounterHistories in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isMessageCounterEnabled()
isMessageCounterEnabled in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic long getMessageCounterSamplePeriod()
getMessageCounterSamplePeriod in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic void setMessageCounterSamplePeriod(long newPeriod)
setMessageCounterSamplePeriod in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic int getMessageCounterMaxDayCount()
getMessageCounterMaxDayCount in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic void setMessageCounterMaxDayCount(int count)
setMessageCounterMaxDayCount in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String[] listPreparedTransactions()
listPreparedTransactions in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String listPreparedTransactionDetailsAsJSON() throws Exception
listPreparedTransactionDetailsAsJSON in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String listPreparedTransactionDetailsAsHTML() throws Exception
listPreparedTransactionDetailsAsHTML in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String[] listHeuristicCommittedTransactions()
listHeuristicCommittedTransactions in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String[] listHeuristicRolledBackTransactions()
listHeuristicRolledBackTransactions in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean commitPreparedTransaction(String transactionAsBase64) throws Exception
commitPreparedTransaction in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic boolean rollbackPreparedTransaction(String transactionAsBase64) throws Exception
rollbackPreparedTransaction in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String[] listRemoteAddresses()
listRemoteAddresses in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String[] listRemoteAddresses(String ipAddress)
listRemoteAddresses in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean closeConnectionsForAddress(String ipAddress)
closeConnectionsForAddress in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean closeConsumerConnectionsForAddress(String address)
closeConsumerConnectionsForAddress in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean closeConnectionsForUser(String userName)
closeConnectionsForUser in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String[] listConnectionIDs()
listConnectionIDs in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String[] listSessions(String connectionID)
listSessions in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String listProducersInfoAsJSON() throws Exception
listProducersInfoAsJSON in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String listConnectionsAsJSON() throws Exception
listConnectionsAsJSON in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String listSessionsAsJSON(String connectionID) throws Exception
listSessionsAsJSON in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String listConsumersAsJSON(String connectionID) throws Exception
listConsumersAsJSON in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String listAllConsumersAsJSON() throws Exception
listAllConsumersAsJSON in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic Object[] getConnectors() throws Exception
getConnectors in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String getConnectorsAsJSON() throws Exception
getConnectorsAsJSON in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void addSecuritySettings(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles) throws Exception
addSecuritySettings in interface org.apache.activemq.artemis.api.core.management.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 org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void removeSecuritySettings(String addressMatch) throws Exception
removeSecuritySettings in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic Object[] getRoles(String addressMatch) throws Exception
getRoles in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String getRolesAsJSON(String addressMatch) throws Exception
getRolesAsJSON in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String getAddressSettingsAsJSON(String address) throws Exception
getAddressSettingsAsJSON in interface org.apache.activemq.artemis.api.core.management.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
addAddressSettings in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void removeAddressSettings(String addressMatch) throws Exception
removeAddressSettings in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void sendQueueInfoToQueue(String queueName, String address) throws Exception
sendQueueInfoToQueue in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String[] getDivertNames()
getDivertNames in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic void createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName) throws Exception
createDivert in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void destroyDivert(String name) throws Exception
destroyDivert in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String[] getBridgeNames()
getBridgeNames in interface org.apache.activemq.artemis.api.core.management.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 org.apache.activemq.artemis.api.core.management.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 org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void destroyBridge(String name) throws Exception
destroyBridge in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void createConnectorService(String name, String factoryClass, Map<String,Object> parameters) throws Exception
createConnectorService in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void destroyConnectorService(String name) throws Exception
destroyConnectorService in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic String[] getConnectorServices()
getConnectorServices in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic void forceFailover()
throws Exception
forceFailover in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void updateDuplicateIdCache(String address, Object[] ids) throws Exception
updateDuplicateIdCache in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlExceptionpublic void scaleDown(String connector) throws Exception
scaleDown in interface org.apache.activemq.artemis.api.core.management.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()
getConnectionTTLOverride in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic int getIDCacheSize()
getIDCacheSize in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String getLargeMessagesDirectory()
getLargeMessagesDirectory in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String getManagementAddress()
getManagementAddress in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic String getManagementNotificationAddress()
getManagementNotificationAddress in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic long getMessageExpiryScanPeriod()
getMessageExpiryScanPeriod in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic long getMessageExpiryThreadPriority()
getMessageExpiryThreadPriority in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic long getTransactionTimeout()
getTransactionTimeout in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic long getTransactionTimeoutScanPeriod()
getTransactionTimeoutScanPeriod in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isPersistDeliveryCountBeforeDelivery()
isPersistDeliveryCountBeforeDelivery in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isPersistIDCache()
isPersistIDCache in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlpublic boolean isWildcardRoutingEnabled()
isWildcardRoutingEnabled in interface org.apache.activemq.artemis.api.core.management.ActiveMQServerControlprotected MBeanOperationInfo[] fillMBeanOperationInfo()
fillMBeanOperationInfo in class AbstractControlprotected MBeanAttributeInfo[] fillMBeanAttributeInfo()
fillMBeanAttributeInfo in class AbstractControlpublic void onNotification(org.apache.activemq.artemis.core.server.management.Notification notification)
onNotification in interface org.apache.activemq.artemis.core.server.management.NotificationListenerCopyright © 2023 The Apache Software Foundation. All rights reserved.