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

Class BroadcastGroupControlImpl

java.lang.Object

javax.management.StandardMBean

org.apache.activemq.artemis.core.management.impl.AbstractControl

org.apache.activemq.artemis.core.management.impl.BroadcastGroupControlImpl

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, ActiveMQComponentControl, BroadcastGroupControl

public class BroadcastGroupControlImpl
extends AbstractControl
implements BroadcastGroupControl

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.management.impl.AbstractControl

storageManager

Constructor Summary

Constructors

Constructor and Description
BroadcastGroupControlImpl(BroadcastGroup broadcastGroup, StorageManager storageManager, BroadcastGroupConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
protected MBeanAttributeInfo[]	fillMBeanAttributeInfo()
protected MBeanOperationInfo[]	fillMBeanOperationInfo()
long	getBroadcastPeriod() Returns the period used by this broadcast group.
Object[]	getConnectorPairs() Returns the pairs of live-backup connectors that are broadcasted by this broadcast group.
String	getConnectorPairsAsJSON() Returns the pairs of live-backup connectors that are broadcasted by this broadcast group using JSON serialization.
String	getGroupAddress() Returns the address this broadcast group is broadcasting to.
int	getGroupPort() Returns the port this broadcast group is broadcasting to.
int	getLocalBindPort() Returns the local port this broadcast group is bound to.
String	getName() Returns the configuration name of this broadcast group.
boolean	isStarted() Returns true if this component is started, false else.
void	start() Starts this component.
void	stop() Stops this component.

Methods inherited from class org.apache.activemq.artemis.core.management.impl.AbstractControl

blockOnIO, clearIO, getMBeanInfo

Methods inherited from class javax.management.StandardMBean

cacheMBeanInfo, 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, setImplementation

Methods inherited from class java.lang.Object

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

Constructor Detail

BroadcastGroupControlImpl

public BroadcastGroupControlImpl(BroadcastGroup broadcastGroup,
                                 StorageManager storageManager,
                                 BroadcastGroupConfiguration configuration)
                          throws Exception

Throws:

Exception

Method Detail

getName

public String getName()

Description copied from interface: BroadcastGroupControl

Returns the configuration name of this broadcast group.

Specified by:

getName in interface BroadcastGroupControl

getBroadcastPeriod

public long getBroadcastPeriod()

Description copied from interface: BroadcastGroupControl

Returns the period used by this broadcast group.

Specified by:

getBroadcastPeriod in interface BroadcastGroupControl

getConnectorPairs

public Object[] getConnectorPairs()

Description copied from interface: BroadcastGroupControl

Returns the pairs of live-backup connectors that are broadcasted by this broadcast group.

Specified by:

getConnectorPairs in interface BroadcastGroupControl

getConnectorPairsAsJSON

public String getConnectorPairsAsJSON()
                               throws Exception

Description copied from interface: BroadcastGroupControl

Returns the pairs of live-backup connectors that are broadcasted by this broadcast group using JSON serialization.

Specified by:

getConnectorPairsAsJSON in interface BroadcastGroupControl

Throws:

Exception

getGroupAddress

public String getGroupAddress()
                       throws Exception

Description copied from interface: BroadcastGroupControl

Returns the address this broadcast group is broadcasting to.

Specified by:

getGroupAddress in interface BroadcastGroupControl

Throws:

Exception

getGroupPort

public int getGroupPort()
                 throws Exception

Description copied from interface: BroadcastGroupControl

Returns the port this broadcast group is broadcasting to.

Specified by:

getGroupPort in interface BroadcastGroupControl

Throws:

Exception

getLocalBindPort

public int getLocalBindPort()
                     throws Exception

Description copied from interface: BroadcastGroupControl

Returns the local port this broadcast group is bound to.

Specified by:

getLocalBindPort in interface BroadcastGroupControl

Throws:

Exception

isStarted

public boolean isStarted()

Description copied from interface: ActiveMQComponentControl

Returns true if this component is started, false else.

Specified by:

isStarted in interface ActiveMQComponentControl

start

public void start()
           throws Exception

Description copied from interface: ActiveMQComponentControl

Starts this component.

Specified by:

start in interface ActiveMQComponentControl

Throws:

Exception

stop

public void stop()
          throws Exception

Description copied from interface: ActiveMQComponentControl

Stops this component.

Specified by:

stop in interface ActiveMQComponentControl

Throws:

Exception

fillMBeanOperationInfo

protected MBeanOperationInfo[] fillMBeanOperationInfo()

Specified by:

fillMBeanOperationInfo in class AbstractControl

fillMBeanAttributeInfo

protected MBeanAttributeInfo[] fillMBeanAttributeInfo()

Specified by:

fillMBeanAttributeInfo in class AbstractControl