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

Class BridgeControlImpl

java.lang.Object

javax.management.StandardMBean

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

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

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, ActiveMQComponentControl, BridgeControl

public class BridgeControlImpl
extends AbstractControl
implements BridgeControl

Field Summary

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

storageManager

Constructor Summary

Constructors

Constructor	Description
BridgeControlImpl(Bridge bridge, StorageManager storageManager)

Method Summary

Modifier and Type	Method	Description
protected MBeanAttributeInfo[]	fillMBeanAttributeInfo()
protected MBeanOperationInfo[]	fillMBeanOperationInfo()
String	getDiscoveryGroupName()	Returns the name of the discovery group used by this bridge.
String	getFilterString()	Returns the filter string associated with this bridge.
String	getForwardingAddress()	Returns the address this bridge will forward messages to.
long	getMaxRetryInterval()	Returns the max retry interval used by this bridge.
long	getMessagesAcknowledged()	The messagesAcknowledged counter is the number of messages actually received by the remote broker.
long	getMessagesPendingAcknowledgement()	The messagesPendingAcknowledgement counter is incremented when the bridge is has forwarded a message but is waiting acknowledgement from the other broker.
Map<String,Object>	getMetrics()	The bridge metrics for this bridge
String	getName()	Returns the name of this bridge.
String	getQueueName()	Returns the name of the queue this bridge is consuming messages from.
int	getReconnectAttempts()	Returns the number of reconnection attempts used by this bridge.
long	getRetryInterval()	Returns the retry interval used by this bridge.
double	getRetryIntervalMultiplier()	Returns the retry interval multiplier used by this bridge.
String[]	getStaticConnectors()	Returns any list of static connectors used by this bridge.
String	getTransformerClassName()	Returns the name of the org.apache.activemq.artemis.core.server.cluster.Transformer implementation associated with this bridge.
Map<String,String>	getTransformerProperties()	Returns a map of the properties configured for the transformer.
String	getTransformerPropertiesAsJSON()	Returns a map of the properties configured for the transformer.
boolean	isConnected()	Returns whether the bridge is actively connected to the remote broker.
boolean	isHA()	Returns whether this bridge is using high availability.
boolean	isStarted()	Returns true if this component is started, false else..
boolean	isUseDuplicateDetection()	Returns whether this bridge is using duplicate detection.
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, sendMessage, tcclCall, tcclInvoke

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 Details

BridgeControlImpl

public BridgeControlImpl(Bridge bridge,
 StorageManager storageManager)
                  throws Exception

Throws:

Exception

Method Details

getStaticConnectors

public String[] getStaticConnectors()
                             throws Exception

Description copied from interface: BridgeControl

Returns any list of static connectors used by this bridge.

Specified by:

getStaticConnectors in interface BridgeControl

Returns:

any list of static connectors used by this bridge

Throws:

Exception

getForwardingAddress

public String getForwardingAddress()

Description copied from interface: BridgeControl

Returns the address this bridge will forward messages to.

Specified by:

getForwardingAddress in interface BridgeControl

Returns:

the address this bridge will forward messages to

getQueueName

public String getQueueName()

Description copied from interface: BridgeControl

Returns the name of the queue this bridge is consuming messages from.

Specified by:

getQueueName in interface BridgeControl

Returns:

the name of the queue this bridge is consuming messages from

getDiscoveryGroupName

public String getDiscoveryGroupName()

Description copied from interface: BridgeControl

Returns the name of the discovery group used by this bridge.

Specified by:

getDiscoveryGroupName in interface BridgeControl

Returns:

the name of the discovery group used by this bridge

getFilterString

public String getFilterString()

Description copied from interface: BridgeControl

Returns the filter string associated with this bridge.

Specified by:

getFilterString in interface BridgeControl

Returns:

the filter string associated with this bridge

getReconnectAttempts

public int getReconnectAttempts()

Description copied from interface: BridgeControl

Returns the number of reconnection attempts used by this bridge.

Specified by:

getReconnectAttempts in interface BridgeControl

Returns:

the number of reconnection attempts used by this bridge

getName

public String getName()

Description copied from interface: BridgeControl

Returns the name of this bridge.

Specified by:

getName in interface BridgeControl

Returns:

the name of this bridge

getRetryInterval

public long getRetryInterval()

Description copied from interface: BridgeControl

Returns the retry interval used by this bridge.

Specified by:

getRetryInterval in interface BridgeControl

Returns:

the retry interval used by this bridge

getRetryIntervalMultiplier

public double getRetryIntervalMultiplier()

Description copied from interface: BridgeControl

Returns the retry interval multiplier used by this bridge.

Specified by:

getRetryIntervalMultiplier in interface BridgeControl

Returns:

the retry interval multiplier used by this bridge

getMaxRetryInterval

public long getMaxRetryInterval()

Description copied from interface: BridgeControl

Returns the max retry interval used by this bridge.

Specified by:

getMaxRetryInterval in interface BridgeControl

Returns:

the max retry interval used by this bridge

getTransformerClassName

public String getTransformerClassName()

Description copied from interface: BridgeControl

Returns the name of the org.apache.activemq.artemis.core.server.cluster.Transformer implementation associated with this bridge.

Specified by:

getTransformerClassName in interface BridgeControl

Returns:

the name of the org.apache.activemq.artemis.core.server.cluster.Transformer implementation associated with this bridge

getTransformerPropertiesAsJSON

public String getTransformerPropertiesAsJSON()

Description copied from interface: BridgeControl

Returns a map of the properties configured for the transformer.

Specified by:

getTransformerPropertiesAsJSON in interface BridgeControl

Returns:

a map of the properties configured for the transformer

getTransformerProperties

public Map<String,String> getTransformerProperties()

Description copied from interface: BridgeControl

Returns a map of the properties configured for the transformer.

Specified by:

getTransformerProperties in interface BridgeControl

Returns:

a map of the properties configured for the transformer

isStarted

public boolean isStarted()

Description copied from interface: ActiveMQComponentControl

Returns true if this component is started, false else..

Specified by:

isStarted in interface ActiveMQComponentControl

Returns:

true if this component is started, false else.

isUseDuplicateDetection

public boolean isUseDuplicateDetection()

Description copied from interface: BridgeControl

Returns whether this bridge is using duplicate detection.

Specified by:

isUseDuplicateDetection in interface BridgeControl

Returns:

whether this bridge is using duplicate detection

isHA

public boolean isHA()

Description copied from interface: BridgeControl

Returns whether this bridge is using high availability.

Specified by:

isHA in interface BridgeControl

Returns:

whether this bridge is using high availability

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

getMessagesPendingAcknowledgement

public long getMessagesPendingAcknowledgement()

Description copied from interface: BridgeControl

The messagesPendingAcknowledgement counter is incremented when the bridge is has forwarded a message but is waiting acknowledgement from the other broker. This is a cumulative total and the number of outstanding pending messages can be computed by subtracting messagesAcknowledged from messagesPendingAcknowledgement.

Specified by:

getMessagesPendingAcknowledgement in interface BridgeControl

getMessagesAcknowledged

public long getMessagesAcknowledged()

Description copied from interface: BridgeControl

The messagesAcknowledged counter is the number of messages actually received by the remote broker. This is a cumulative total and the number of outstanding pending messages can be computed by subtracting messagesAcknowledged from messagesPendingAcknowledgement.

Specified by:

getMessagesAcknowledged in interface BridgeControl

getMetrics

public Map<String,Object> getMetrics()

Description copied from interface: BridgeControl

The bridge metrics for this bridge

The messagesPendingAcknowledgement counter is incremented when the bridge is has forwarded a message but is waiting acknowledgement from the other broker. The messagesAcknowledged counter is the number of messages actually received by the remote broker.

Specified by:

getMetrics in interface BridgeControl

isConnected

public boolean isConnected()

Description copied from interface: BridgeControl

Returns whether the bridge is actively connected to the remote broker.

Specified by:

isConnected in interface BridgeControl

Returns:

whether the bridge is actively connected to the remote broker