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 and Description
ManagementServiceImpl(MBeanServer mbeanServer, Configuration configuration)

Method Summary

Modifier and Type	Method and Description
void	addNotificationListener(NotificationListener listener)
void	enableNotifications(boolean enabled)
Object	getAttribute(String resourceName, String attribute)
SimpleString	getManagementAddress()
SimpleString	getManagementNotificationAddress()
MessageCounterManager	getMessageCounterManager()
ObjectNameBuilder	getObjectNameBuilder()
Object	getResource(String resourceName)
Object[]	getResources(Class<?> resourceType)
ServerMessage	handleMessage(ServerMessage message)
boolean	isStarted()
void	registerAcceptor(Acceptor acceptor, TransportConfiguration configuration)
void	registerAddress(SimpleString address)
void	registerBridge(Bridge bridge, BridgeConfiguration configuration)
void	registerBroadcastGroup(BroadcastGroup broadcastGroup, BroadcastGroupConfiguration configuration)
void	registerCluster(ClusterConnection cluster, ClusterConnectionConfiguration configuration)
void	registerDivert(Divert divert, DivertConfiguration config)
void	registerInJMX(ObjectName objectName, Object managedResource)
void	registerInRegistry(String resourceName, Object managedResource)
void	registerQueue(Queue queue, SimpleString address, StorageManager storageManager)
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)
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	unregisterCluster(String name)
void	unregisterDivert(SimpleString name)
void	unregisterFromJMX(ObjectName objectName)
void	unregisterFromRegistry(String resourceName)
void	unregisterQueue(SimpleString name, SimpleString address)
void	unregisterServer()

Methods inherited from class java.lang.Object

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

Constructor Detail

ManagementServiceImpl

public ManagementServiceImpl(MBeanServer mbeanServer,
                             Configuration configuration)

Method Detail

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(SimpleString address)
                     throws Exception

Specified by:

registerAddress in interface ManagementService

Throws:

Exception

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)
                     throws Exception

Specified by:

unregisterQueue in interface ManagementService

Throws:

Exception

registerDivert

public void registerDivert(Divert divert,
                           DivertConfiguration config)
                    throws Exception

Specified by:

registerDivert in interface ManagementService

Throws:

Exception

unregisterDivert

public void unregisterDivert(SimpleString name)
                      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

registerBridge

public void registerBridge(Bridge bridge,
                           BridgeConfiguration configuration)
                    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

handleMessage

public ServerMessage handleMessage(ServerMessage message)
                            throws Exception

Specified by:

handleMessage in interface ManagementService

Throws:

Exception

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

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

unregisterFromJMX

public void unregisterFromJMX(ObjectName objectName)
                       throws MBeanRegistrationException,
                              InstanceNotFoundException

Specified by:

unregisterFromJMX in interface ManagementService

Throws:

MBeanRegistrationException

InstanceNotFoundException

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)