Class AMQPBridgeSenderControlType

java.lang.Object

javax.management.StandardMBean

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

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

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, AMQPBridgeSenderControl

public class AMQPBridgeSenderControlType
extends org.apache.activemq.artemis.core.management.impl.AbstractControl
implements AMQPBridgeSenderControl

Management object used for AMQP bridge address and queue senders to expose sender state.

Field Summary

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

storageManager

Constructor Summary

Constructors

Constructor	Description
AMQPBridgeSenderControlType(AMQPBridgeToSenderController senderController)

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 sender instance.
String	getFilterString()	Gets the filter string that will be used when creating the bridge sender.
String	getFqqn()	Gets the local FQQN that comprises the address and queue where the remote sender will be attached.
long	getMessagesSent()	Returns the number of messages this bridge sender has sent to the remote.
int	getPriority()	Gets the priority value that will be requested for the local subscription that feeds this bridge sender with messages to send to the remote.
String	getQueueName()	Gets the queue name that will be used for this bridge sender instance.
String	getRole()	Returns the type of bridge sender being represented.
String	getRoutingType()	Gets the routing type that will be requested when creating a sender on the local 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

AMQPBridgeSenderControlType

public AMQPBridgeSenderControlType(AMQPBridgeToSenderController senderController)
                            throws NotCompliantMBeanException

Throws:

NotCompliantMBeanException

Method Details

getMessagesSent

public long getMessagesSent()

Description copied from interface: AMQPBridgeSenderControl

Returns the number of messages this bridge sender has sent to the remote.

Specified by:

getMessagesSent in interface AMQPBridgeSenderControl

Returns:

the number of messages this bridge sender has sent to the remote

getRole

public String getRole()

Description copied from interface: AMQPBridgeSenderControl

Returns the type of bridge sender being represented.

Specified by:

getRole in interface AMQPBridgeSenderControl

Returns:

the type of bridge sender being represented

getQueueName

public String getQueueName()

Description copied from interface: AMQPBridgeSenderControl

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

Specified by:

getQueueName in interface AMQPBridgeSenderControl

Returns:

the queue name associated with the bridge sender

getAddress

public String getAddress()

Description copied from interface: AMQPBridgeSenderControl

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

Specified by:

getAddress in interface AMQPBridgeSenderControl

Returns:

the address associated with this bridge sender.

getFqqn

public String getFqqn()

Description copied from interface: AMQPBridgeSenderControl

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

Specified by:

getFqqn in interface AMQPBridgeSenderControl

Returns:

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

getRoutingType

public String getRoutingType()

Description copied from interface: AMQPBridgeSenderControl

Gets the routing type that will be requested when creating a sender on the local server.

Specified by:

getRoutingType in interface AMQPBridgeSenderControl

Returns:

the routing type of the bridge sender.

getFilterString

public String getFilterString()

Description copied from interface: AMQPBridgeSenderControl

Gets the filter string that will be used when creating the bridge sender. This is the filter string that is applied to the local subscription used to filter which message are actually sent to the remote broker.

Specified by:

getFilterString in interface AMQPBridgeSenderControl

Returns:

the filter string in use for the bridge sender.

getPriority

public int getPriority()

Description copied from interface: AMQPBridgeSenderControl

Gets the priority value that will be requested for the local subscription that feeds this bridge sender with messages to send to the remote.

Specified by:

getPriority in interface AMQPBridgeSenderControl

Returns:

the assigned sender priority for the bridge sender.

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