com.communote.plugins.mq.provider.activemq

Class ActiveMQBroker

java.lang.Object

com.communote.plugins.mq.provider.activemq.ActiveMQBroker

All Implemented Interfaces:

ConfigurableBroker, MonitorableBroker

public class ActiveMQBroker
extends Object
implements ConfigurableBroker, MonitorableBroker

Delivers ActiveMQ broker.

Author:

Communote GmbH - http://www.communote.com/

Constructor Summary

Constructors

Constructor and Description
ActiveMQBroker(org.osgi.framework.BundleContext bc)

Method Summary

Modifier and Type	Method and Description
void	activateBroker() starts ActiveMQ broker.
void	deactivateBroker() stops ActiveMQ broker.
String	getBrokerName()
Set<BrokerQueue>	getBrokerQueues()
MessageHandlerMQConsumer[]	getMessageHandlerConsumers()
void	initBrokerInstance() is invoked by OSGi.
void	invalidateBrokerInstance() is invoked by OSGi.
boolean	isActive()

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveMQBroker

public ActiveMQBroker(org.osgi.framework.BundleContext bc)

Parameters:

bc - bundle context

Method Detail

activateBroker

public void activateBroker()
                    throws Exception

starts ActiveMQ broker.

Specified by:

activateBroker in interface ConfigurableBroker

Throws:

Exception - the exception

deactivateBroker

public void deactivateBroker()
                      throws Exception

stops ActiveMQ broker. Is invoked explicitly by administrator.

Specified by:

deactivateBroker in interface ConfigurableBroker

Throws:

Exception - the exception

getBrokerName

public String getBrokerName()
                     throws MessageQueueJmxException

Specified by:

getBrokerName in interface MonitorableBroker

Returns:

broker name

Throws:

MessageQueueJmxException

getBrokerQueues

public Set<BrokerQueue> getBrokerQueues()
                                 throws MessageQueueJmxException

Specified by:

getBrokerQueues in interface MonitorableBroker

Returns:

existing message queues

Throws:

MessageQueueJmxException

getMessageHandlerConsumers

public MessageHandlerMQConsumer[] getMessageHandlerConsumers()
                                                      throws MessageQueueJmxException

Specified by:

getMessageHandlerConsumers in interface MonitorableBroker

Returns:

consumers, which are used to deliver message to an appropriate message handler

Throws:

MessageQueueJmxException

initBrokerInstance

public void initBrokerInstance()
                        throws Exception

is invoked by OSGi. If during previous session the broker was not stopped explicitly by administrator, it will be started now

Throws:

Exception - exception

invalidateBrokerInstance

public void invalidateBrokerInstance()
                              throws Exception

is invoked by OSGi. This invocation should not change flag isStarted in settings. During next start broker will be automatically started

Throws:

Exception - exception

isActive

public boolean isActive()

Specified by:

isActive in interface ConfigurableBroker

Specified by:

isActive in interface MonitorableBroker

Returns:

whether broker is currently started or not