Package org.apache.activemq.artemis.core.server.management

Interface ManagementService

All Superinterfaces:

ActiveMQComponent, NotificationService

All Known Implementing Classes:

ManagementServiceImpl

public interface ManagementService
extends NotificationService, ActiveMQComponent

Method Summary

Modifier and Type	Method	Description
Object	getAttribute(String resourceName, String attribute, SecurityAuth auth)
SimpleString	getManagementAddress()
SimpleString	getManagementNotificationAddress()
MessageCounterManager	getMessageCounterManager()
ObjectNameBuilder	getObjectNameBuilder()
Object	getResource(String resourceName)
Object[]	getResources(Class<?> resourceType)
ICoreMessage	handleMessage(SecurityAuth auth, Message message)
Object	invokeOperation(String resourceName, String operation, Object[] params, SecurityAuth auth)
void	registerAcceptor(Acceptor acceptor, TransportConfiguration configuration)
void	registerAddress(AddressInfo addressInfo)
void	registerAddressMeters(AddressInfo addressInfo, AddressControl addressControl)
void	registerBridge(Bridge bridge)
void	registerBroadcastGroup(BroadcastGroup broadcastGroup, BroadcastGroupConfiguration configuration)
void	registerBrokerConnection(BrokerConnection brokerConnection)
void	registerCluster(ClusterConnection cluster, ClusterConnectionConfiguration configuration)
void	registerConnectionRouter(ConnectionRouter router)
void	registerDivert(Divert divert)
void	registerHawtioSecurity(GuardInvocationHandler guardInvocationHandler)
void	registerInJMX(ObjectName objectName, Object managedResource)
void	registerInRegistry(String resourceName, Object managedResource)
void	registerQueue(Queue queue, SimpleString address, StorageManager storageManager)
void	registerRemoteBrokerConnection(RemoteBrokerConnection brokerConnection)
ActiveMQServerControlImpl	registerServer(PostOffice postOffice, SecurityStore securityStore, StorageManager storageManager, Configuration configuration, HierarchicalRepository<AddressSettings> addressSettingsRepository, HierarchicalRepository<Set<Role>> securityRepository, ResourceManager resourceManager, RemotingService remotingService, ActiveMQServer messagingServer, QueueFactory queueFactory, ScheduledExecutorService scheduledThreadPool, PagingManager pagingManager, boolean backup)
void	setStorageManager(StorageManager storageManager)
void	unregisterAcceptors()
void	unregisterAddress(SimpleString address)
void	unregisterBridge(String name)
void	unregisterBroadcastGroup(String name)
void	unregisterBrokerConnection(String name)
void	unregisterCluster(String name)
void	unregisterConnectionRouter(String name)
void	unregisterDivert(SimpleString name, SimpleString address)
void	unregisterFromJMX(ObjectName objectName)
void	unregisterFromRegistry(String resourceName)
void	unregisterHawtioSecurity()
void	unregisterQueue(SimpleString name, SimpleString address, RoutingType routingType)
void	unregisterRemoteBrokerConnection(String nodeId, String name)
void	unregisterServer()

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop, isStarted, start, stop

Methods inherited from interface org.apache.activemq.artemis.core.server.management.NotificationService

addNotificationListener, enableNotifications, removeNotificationListener, sendNotification

Method Details

getMessageCounterManager

MessageCounterManager getMessageCounterManager()

getManagementAddress

SimpleString getManagementAddress()

getManagementNotificationAddress

SimpleString getManagementNotificationAddress()

getObjectNameBuilder

ObjectNameBuilder getObjectNameBuilder()

setStorageManager

void setStorageManager(StorageManager storageManager)

registerServer

ActiveMQServerControlImpl registerServer(PostOffice postOffice,
 SecurityStore securityStore,
 StorageManager storageManager,
 Configuration configuration,
 HierarchicalRepository<AddressSettings> addressSettingsRepository,
 HierarchicalRepository<Set<Role>> securityRepository,
 ResourceManager resourceManager,
 RemotingService remotingService,
 ActiveMQServer messagingServer,
 QueueFactory queueFactory,
 ScheduledExecutorService scheduledThreadPool,
 PagingManager pagingManager,
 boolean backup)
                                  throws Exception

Throws:

Exception

unregisterServer

void unregisterServer()
               throws Exception

Throws:

Exception

registerInJMX

void registerInJMX(ObjectName objectName,
 Object managedResource)
            throws Exception

Throws:

Exception

unregisterFromJMX

void unregisterFromJMX(ObjectName objectName)
                throws Exception

Throws:

Exception

registerInRegistry

void registerInRegistry(String resourceName,
 Object managedResource)

unregisterFromRegistry

void unregisterFromRegistry(String resourceName)

registerAddress

void registerAddress(AddressInfo addressInfo)
              throws Exception

Throws:

Exception

registerAddressMeters

void registerAddressMeters(AddressInfo addressInfo,
 AddressControl addressControl)
                    throws Exception

Throws:

Exception

unregisterAddress

void unregisterAddress(SimpleString address)
                throws Exception

Throws:

Exception

registerQueue

void registerQueue(Queue queue,
 SimpleString address,
 StorageManager storageManager)
            throws Exception

Throws:

Exception

unregisterQueue

void unregisterQueue(SimpleString name,
 SimpleString address,
 RoutingType routingType)
              throws Exception

Throws:

Exception

registerAcceptor

void registerAcceptor(Acceptor acceptor,
 TransportConfiguration configuration)
               throws Exception

Throws:

Exception

unregisterAcceptors

void unregisterAcceptors()

registerDivert

void registerDivert(Divert divert)
             throws Exception

Throws:

Exception

unregisterDivert

void unregisterDivert(SimpleString name,
 SimpleString address)
               throws Exception

Throws:

Exception

registerBroadcastGroup

void registerBroadcastGroup(BroadcastGroup broadcastGroup,
 BroadcastGroupConfiguration configuration)
                     throws Exception

Throws:

Exception

unregisterBroadcastGroup

void unregisterBroadcastGroup(String name)
                       throws Exception

Throws:

Exception

registerBridge

void registerBridge(Bridge bridge)
             throws Exception

Throws:

Exception

unregisterBridge

void unregisterBridge(String name)
               throws Exception

Throws:

Exception

registerCluster

void registerCluster(ClusterConnection cluster,
 ClusterConnectionConfiguration configuration)
              throws Exception

Throws:

Exception

unregisterCluster

void unregisterCluster(String name)
                throws Exception

Throws:

Exception

registerConnectionRouter

void registerConnectionRouter(ConnectionRouter router)
                       throws Exception

Throws:

Exception

unregisterConnectionRouter

void unregisterConnectionRouter(String name)
                         throws Exception

Throws:

Exception

registerBrokerConnection

void registerBrokerConnection(BrokerConnection brokerConnection)
                       throws Exception

Throws:

Exception

unregisterBrokerConnection

void unregisterBrokerConnection(String name)
                         throws Exception

Throws:

Exception

registerRemoteBrokerConnection

void registerRemoteBrokerConnection(RemoteBrokerConnection brokerConnection)
                             throws Exception

Throws:

Exception

unregisterRemoteBrokerConnection

void unregisterRemoteBrokerConnection(String nodeId,
 String name)
                               throws Exception

Throws:

Exception

getResource

Object getResource(String resourceName)

getResources

Object[] getResources(Class<?> resourceType)

handleMessage

ICoreMessage handleMessage(SecurityAuth auth,
 Message message)
                    throws Exception

Throws:

Exception

registerHawtioSecurity

void registerHawtioSecurity(GuardInvocationHandler guardInvocationHandler)
                     throws Exception

Throws:

Exception

unregisterHawtioSecurity

void unregisterHawtioSecurity()
                       throws Exception

Throws:

Exception

getAttribute

Object getAttribute(String resourceName,
 String attribute,
 SecurityAuth auth)

invokeOperation

Object invokeOperation(String resourceName,
 String operation,
 Object[] params,
 SecurityAuth auth)
                throws Exception

Throws:

Exception