Class AMQPFederationProducerControlType

java.lang.Object

javax.management.StandardMBean

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

org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationProducerControlType

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, AMQPFederationProducerControl

public class AMQPFederationProducerControlType
extends org.apache.activemq.artemis.core.management.impl.AbstractControl
implements AMQPFederationProducerControl

Management object used for AMQP federation address and queue producer to expose producer state.

Field Summary

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

storageManager

Constructor Summary

Constructors

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

AMQPFederationProducerControlType

public AMQPFederationProducerControlType(AMQPFederationSenderController senderController)
                                  throws NotCompliantMBeanException

Throws:

NotCompliantMBeanException

Method Details

getMessagesSent

public long getMessagesSent()

Description copied from interface: AMQPFederationProducerControl

Returns the number of messages this federation producer has sent to the remote.

Specified by:

getMessagesSent in interface AMQPFederationProducerControl

Returns:

the number of messages this federation producer has sent to the remote

getRole

public String getRole()

Description copied from interface: AMQPFederationProducerControl

Returns the type of federation producer being represented.

Specified by:

getRole in interface AMQPFederationProducerControl

Returns:

the type of federation producer being represented

getQueueName

public String getQueueName()

Description copied from interface: AMQPFederationProducerControl

Gets the queue name that will be used for this federation producer instance.

For Queue federation this will be the name of the queue whose messages are being federated from this server instance to the remote. For an Address federation this will be an automatically generated name that should be unique to a given federation producer instance.

Specified by:

getQueueName in interface AMQPFederationProducerControl

Returns:

the queue name associated with the federation producer

getAddress

public String getAddress()

Description copied from interface: AMQPFederationProducerControl

Gets the address that will be used for this federation producer instance.

For Queue federation this is the address under which the matching queue must reside. For Address federation this is the actual subscription address whose messages are being federated from the local address.

Specified by:

getAddress in interface AMQPFederationProducerControl

Returns:

the address associated with this federation producer

getFqqn

public String getFqqn()

Description copied from interface: AMQPFederationProducerControl

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

Specified by:

getFqqn in interface AMQPFederationProducerControl

Returns:

provides the FQQN that can be used to address the producer queue directly

getRoutingType

public String getRoutingType()

Description copied from interface: AMQPFederationProducerControl

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

Specified by:

getRoutingType in interface AMQPFederationProducerControl

Returns:

the routing type of the federation producer

getFilterString

public String getFilterString()

Description copied from interface: AMQPFederationProducerControl

Gets the filter string that will be used when creating the federation producer.

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 AMQPFederationProducerControl

Returns:

the filter string that will be used when creating the federation producer

getPriority

public int getPriority()

Description copied from interface: AMQPFederationProducerControl

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

Specified by:

getPriority in interface AMQPFederationProducerControl

Returns:

the assigned producer priority for the federation producer

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