Class AMQPBridgeReceiverControlType

java.lang.Object

javax.management.StandardMBean

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

org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeReceiverControlType

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, AMQPBridgeReceiverControl

public class AMQPBridgeReceiverControlType
extends org.apache.activemq.artemis.core.management.impl.AbstractControl
implements AMQPBridgeReceiverControl

Management object used for AMQP bridge address and queue receivers to expose receiver state.

Field Summary

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

storageManager

Constructor Summary

Constructors

Constructor	Description
AMQPBridgeReceiverControlType(AMQPBridgeReceiver receiver)

Method Summary

Modifier and Type	Method	Description
protected MBeanAttributeInfo[]	fillMBeanAttributeInfo()
protected MBeanOperationInfo[]	fillMBeanOperationInfo()
String	getAddress()	Gets the address that will be used for this bridge receiver instance.
String	getFilterString()	Gets the filter string that will be used when creating the remote receiver.
String	getFqqn()	Gets the FQQN that comprises the address and queue where the remote receiver will be attached.
long	getMessagesReceived()	Returns the number of messages this bridge receiver has received from the remote.
int	getPriority()	Gets the priority value that will be requested for the remote receiver that is created.
String	getQueueName()	Gets the queue name that will be used for this bridge receiver instance.
String	getRole()	Returns the type of bridge receiver being represented.
String	getRoutingType()	Gets the routing type that will be requested when creating a receiver on the remote server.

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

blockOnIO, clearIO, getMBeanInfo, sendMessage, tcclCall, tcclInvoke

Methods inherited from class 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 Object

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

Constructor Details

AMQPBridgeReceiverControlType

public AMQPBridgeReceiverControlType(AMQPBridgeReceiver receiver)
                              throws NotCompliantMBeanException

Throws:

NotCompliantMBeanException

Method Details

getMessagesReceived

public long getMessagesReceived()

Description copied from interface: AMQPBridgeReceiverControl

Returns the number of messages this bridge receiver has received from the remote.

Specified by:

getMessagesReceived in interface AMQPBridgeReceiverControl

Returns:

the number of messages this bridge receiver has received from the remote

getRole

public String getRole()

Description copied from interface: AMQPBridgeReceiverControl

Returns the type of bridge receiver being represented.

Specified by:

getRole in interface AMQPBridgeReceiverControl

Returns:

the type of bridge receiver being represented

getQueueName

public String getQueueName()

Description copied from interface: AMQPBridgeReceiverControl

Gets the queue name that will be used for this bridge receiver instance. For Queue bridge this will be the name of the queue whose messages are being bridged to this server instance. For an Address bridge this will be an automatically generated name that should be unique to a given bridge instance

Specified by:

getQueueName in interface AMQPBridgeReceiverControl

Returns:

the queue name associated with the bridge receiver

getAddress

public String getAddress()

Description copied from interface: AMQPBridgeReceiverControl

Gets the address that will be used for this bridge receiver instance. For Queue bridge this is the address under which the matching queue must reside. For Address bridge this is the actual address whose messages are being bridged.

Specified by:

getAddress in interface AMQPBridgeReceiverControl

Returns:

the address associated with this bridge receiver.

getFqqn

public String getFqqn()

Description copied from interface: AMQPBridgeReceiverControl

Gets the FQQN that comprises the address and queue where the remote receiver will be attached.

Specified by:

getFqqn in interface AMQPBridgeReceiverControl

Returns:

provides the FQQN that can be used to address the receiver queue directly.

getRoutingType

public String getRoutingType()

Description copied from interface: AMQPBridgeReceiverControl

Gets the routing type that will be requested when creating a receiver on the remote server.

Specified by:

getRoutingType in interface AMQPBridgeReceiverControl

Returns:

the routing type of the remote receiver.

getFilterString

public String getFilterString()

Description copied from interface: AMQPBridgeReceiverControl

Gets the filter string that will be used when creating the remote receiver.

For a queue bridge the filter is selected from configuration if one was set or if the consumer that generated to demand that creates the bridge carries a filter that value is chosen, otherwise any filter that is set on the bridged queue is chosen.

For an address bridge the filter only exists if one was set in the bridge from address policy configuration.

Specified by:

getFilterString in interface AMQPBridgeReceiverControl

Returns:

the filter string in use for the bridge receiver.

getPriority

public int getPriority()

Description copied from interface: AMQPBridgeReceiverControl

Gets the priority value that will be requested for the remote receiver that is created.

Specified by:

getPriority in interface AMQPBridgeReceiverControl

Returns:

the assigned receiver priority for the bridge receiver.

fillMBeanOperationInfo

protected MBeanOperationInfo[] fillMBeanOperationInfo()

Specified by:

fillMBeanOperationInfo in class org.apache.activemq.artemis.core.management.impl.AbstractControl

fillMBeanAttributeInfo

protected MBeanAttributeInfo[] fillMBeanAttributeInfo()

Specified by:

fillMBeanAttributeInfo in class org.apache.activemq.artemis.core.management.impl.AbstractControl