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

Class ManagementServiceImpl

java.lang.Object

org.apache.activemq.artemis.core.server.management.impl.ManagementServiceImpl

All Implemented Interfaces:

ActiveMQComponent, ManagementService, NotificationService

public class ManagementServiceImpl
extends Object
implements ManagementService

Constructor Summary

Constructors

Constructor	Description
ManagementServiceImpl(MBeanServer mbeanServer, Configuration configuration)

Method Summary

Modifier and Type	Method	Description
void	addNotificationListener(NotificationListener listener)
void	enableNotifications(boolean enabled)
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)
boolean	isStarted()
protected CheckType	permissionForInvoke(String method)
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 guard)
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 storageManager1, Configuration configuration, HierarchicalRepository<AddressSettings> addressSettingsRepository, HierarchicalRepository<Set<Role>> securityRepository, ResourceManager resourceManager, RemotingService remotingService, ActiveMQServer messagingServer, QueueFactory queueFactory, ScheduledExecutorService scheduledThreadPool, PagingManager pagingManager, boolean backup)
void	removeNotificationListener(NotificationListener listener)
protected void	securityCheck(String controlName, CheckType permission, SecurityAuth auth)
void	sendNotification(Notification notification)	the message corresponding to a notification will always contain the properties: ManagementHelper.HDR_NOTIFICATION_TYPE - the type of notification (SimpleString) ManagementHelper.HDR_NOTIFICATION_MESSAGE - a message contextual to the notification (SimpleString) ManagementHelper.HDR_NOTIFICATION_TIMESTAMP - the timestamp when the notification occurred (long) in addition to the properties defined in props
void	setStorageManager(StorageManager storageManager)
void	start()
void	stop()
void	unregisterAcceptor(String name)
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 class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

asyncStop

Constructor Details

ManagementServiceImpl

public ManagementServiceImpl(MBeanServer mbeanServer,
 Configuration configuration)

Method Details

getObjectNameBuilder

public ObjectNameBuilder getObjectNameBuilder()

Specified by:

getObjectNameBuilder in interface ManagementService

getMessageCounterManager

public MessageCounterManager getMessageCounterManager()

Specified by:

getMessageCounterManager in interface ManagementService

setStorageManager

public void setStorageManager(StorageManager storageManager)

Specified by:

setStorageManager in interface ManagementService

registerServer

public ActiveMQServerControlImpl registerServer(PostOffice postOffice,
 SecurityStore securityStore,
 StorageManager storageManager1,
 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

Specified by:

registerServer in interface ManagementService

Throws:

Exception

unregisterServer

public void unregisterServer()
                      throws Exception

Specified by:

unregisterServer in interface ManagementService

Throws:

Exception

registerAddress

public void registerAddress(AddressInfo addressInfo)
                     throws Exception

Specified by:

registerAddress in interface ManagementService

Throws:

Exception

registerAddressMeters

public void registerAddressMeters(AddressInfo addressInfo,
 AddressControl addressControl)

Specified by:

registerAddressMeters in interface ManagementService

unregisterAddress

public void unregisterAddress(SimpleString address)
                       throws Exception

Specified by:

unregisterAddress in interface ManagementService

Throws:

Exception

registerQueue

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

Specified by:

registerQueue in interface ManagementService

Throws:

Exception

unregisterQueue

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

Specified by:

unregisterQueue in interface ManagementService

Throws:

Exception

registerDivert

public void registerDivert(Divert divert)
                    throws Exception

Specified by:

registerDivert in interface ManagementService

Throws:

Exception

unregisterDivert

public void unregisterDivert(SimpleString name,
 SimpleString address)
                      throws Exception

Specified by:

unregisterDivert in interface ManagementService

Throws:

Exception

registerAcceptor

public void registerAcceptor(Acceptor acceptor,
 TransportConfiguration configuration)
                      throws Exception

Specified by:

registerAcceptor in interface ManagementService

Throws:

Exception

unregisterAcceptors

public void unregisterAcceptors()

Specified by:

unregisterAcceptors in interface ManagementService

unregisterAcceptor

public void unregisterAcceptor(String name)
                        throws Exception

Throws:

Exception

registerBroadcastGroup

public void registerBroadcastGroup(BroadcastGroup broadcastGroup,
 BroadcastGroupConfiguration configuration)
                            throws Exception

Specified by:

registerBroadcastGroup in interface ManagementService

Throws:

Exception

unregisterBroadcastGroup

public void unregisterBroadcastGroup(String name)
                              throws Exception

Specified by:

unregisterBroadcastGroup in interface ManagementService

Throws:

Exception

registerBrokerConnection

public void registerBrokerConnection(BrokerConnection brokerConnection)
                              throws Exception

Specified by:

registerBrokerConnection in interface ManagementService

Throws:

Exception

unregisterBrokerConnection

public void unregisterBrokerConnection(String name)
                                throws Exception

Specified by:

unregisterBrokerConnection in interface ManagementService

Throws:

Exception

registerRemoteBrokerConnection

public void registerRemoteBrokerConnection(RemoteBrokerConnection brokerConnection)
                                    throws Exception

Specified by:

registerRemoteBrokerConnection in interface ManagementService

Throws:

Exception

unregisterRemoteBrokerConnection

public void unregisterRemoteBrokerConnection(String nodeId,
 String name)
                                      throws Exception

Specified by:

unregisterRemoteBrokerConnection in interface ManagementService

Throws:

Exception

registerBridge

public void registerBridge(Bridge bridge)
                    throws Exception

Specified by:

registerBridge in interface ManagementService

Throws:

Exception

unregisterBridge

public void unregisterBridge(String name)
                      throws Exception

Specified by:

unregisterBridge in interface ManagementService

Throws:

Exception

registerCluster

public void registerCluster(ClusterConnection cluster,
 ClusterConnectionConfiguration configuration)
                     throws Exception

Specified by:

registerCluster in interface ManagementService

Throws:

Exception

unregisterCluster

public void unregisterCluster(String name)
                       throws Exception

Specified by:

unregisterCluster in interface ManagementService

Throws:

Exception

registerConnectionRouter

public void registerConnectionRouter(ConnectionRouter router)
                              throws Exception

Specified by:

registerConnectionRouter in interface ManagementService

Throws:

Exception

unregisterConnectionRouter

public void unregisterConnectionRouter(String name)
                                throws Exception

Specified by:

unregisterConnectionRouter in interface ManagementService

Throws:

Exception

registerHawtioSecurity

public void registerHawtioSecurity(GuardInvocationHandler guard)
                            throws Exception

Specified by:

registerHawtioSecurity in interface ManagementService

Throws:

Exception

unregisterHawtioSecurity

public void unregisterHawtioSecurity()
                              throws Exception

Specified by:

unregisterHawtioSecurity in interface ManagementService

Throws:

Exception

handleMessage

public ICoreMessage handleMessage(SecurityAuth auth,
 Message message)
                           throws Exception

Specified by:

handleMessage in interface ManagementService

Throws:

Exception

securityCheck

protected void securityCheck(String controlName,
 CheckType permission,
 SecurityAuth auth)
                      throws Exception

Throws:

Exception

permissionForInvoke

protected CheckType permissionForInvoke(String method)

getResource

public Object getResource(String resourceName)

Specified by:

getResource in interface ManagementService

getResources

public Object[] getResources(Class<?> resourceType)

Specified by:

getResources in interface ManagementService

registerInJMX

public void registerInJMX(ObjectName objectName,
 Object managedResource)
                   throws Exception

Specified by:

registerInJMX in interface ManagementService

Throws:

Exception

unregisterFromJMX

public void unregisterFromJMX(ObjectName objectName)
                       throws MBeanRegistrationException,
InstanceNotFoundException

Specified by:

unregisterFromJMX in interface ManagementService

Throws:

MBeanRegistrationException

InstanceNotFoundException

registerInRegistry

public void registerInRegistry(String resourceName,
 Object managedResource)

Specified by:

registerInRegistry in interface ManagementService

unregisterFromRegistry

public void unregisterFromRegistry(String resourceName)

Specified by:

unregisterFromRegistry in interface ManagementService

addNotificationListener

public void addNotificationListener(NotificationListener listener)

Specified by:

addNotificationListener in interface NotificationService

removeNotificationListener

public void removeNotificationListener(NotificationListener listener)

Specified by:

removeNotificationListener in interface NotificationService

getManagementAddress

public SimpleString getManagementAddress()

Specified by:

getManagementAddress in interface ManagementService

getManagementNotificationAddress

public SimpleString getManagementNotificationAddress()

Specified by:

getManagementNotificationAddress in interface ManagementService

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ActiveMQComponent

sendNotification

public void sendNotification(Notification notification)
                      throws Exception

Description copied from interface: NotificationService

the message corresponding to a notification will always contain the properties:

• ManagementHelper.HDR_NOTIFICATION_TYPE - the type of notification (SimpleString)
• ManagementHelper.HDR_NOTIFICATION_MESSAGE - a message contextual to the notification (SimpleString)
• ManagementHelper.HDR_NOTIFICATION_TIMESTAMP - the timestamp when the notification occurred (long)

in addition to the properties defined in props

Specified by:

sendNotification in interface NotificationService

Throws:

Exception

See Also:

• ManagementHelper

enableNotifications

public void enableNotifications(boolean enabled)

Specified by:

enableNotifications in interface NotificationService

getAttribute

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

Specified by:

getAttribute in interface ManagementService

invokeOperation

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

Specified by:

invokeOperation in interface ManagementService

Throws:

Exception