org.apache.activemq.advisory
Class AdvisorySupport

java.lang.Object
  org.apache.activemq.advisory.AdvisorySupport

public final class AdvisorySupport
extends Object

Field Summary

static String	ADIVSORY_MESSAGE_TYPE
static String	ADVISORY_TOPIC_PREFIX
static String	AGENT_TOPIC
static ActiveMQTopic	CONNECTION_ADVISORY_TOPIC
static String	CONSUMER_ADVISORY_TOPIC_PREFIX
static String	EXPIRED_QUEUE_MESSAGES_TOPIC_PREFIX
static String	EXPIRED_TOPIC_MESSAGES_TOPIC_PREFIX
static String	FAST_PRODUCER_TOPIC_PREFIX
static String	FULL_TOPIC_PREFIX
static String	MASTER_BROKER_TOPIC_PREFIX
static String	MESSAGE_CONSUMED_TOPIC_PREFIX
static String	MESSAGE_DELIVERED_TOPIC_PREFIX
static String	MESSAGE_DISCAREDED_TOPIC_PREFIX
static String	MSG_PROPERTY_CONSUMER_ID
static String	MSG_PROPERTY_MESSAGE_ID
static String	MSG_PROPERTY_ORIGIN_BROKER_ID
static String	MSG_PROPERTY_ORIGIN_BROKER_NAME
static String	MSG_PROPERTY_ORIGIN_BROKER_URL
static String	MSG_PROPERTY_PRODUCER_ID
static String	MSG_PROPERTY_USAGE_NAME
static String	NO_QUEUE_CONSUMERS_TOPIC_PREFIX
static String	NO_TOPIC_CONSUMERS_TOPIC_PREFIX
static String	PRODUCER_ADVISORY_TOPIC_PREFIX
static ActiveMQTopic	QUEUE_ADVISORY_TOPIC
static String	QUEUE_CONSUMER_ADVISORY_TOPIC_PREFIX
static String	QUEUE_PRODUCER_ADVISORY_TOPIC_PREFIX
static String	SLOW_CONSUMER_TOPIC_PREFIX
static ActiveMQTopic	TEMP_DESTINATION_COMPOSITE_ADVISORY_TOPIC
static ActiveMQTopic	TEMP_QUEUE_ADVISORY_TOPIC
static ActiveMQTopic	TEMP_TOPIC_ADVISORY_TOPIC
static ActiveMQTopic	TOPIC_ADVISORY_TOPIC
static String	TOPIC_CONSUMER_ADVISORY_TOPIC_PREFIX
static String	TOPIC_PRODUCER_ADVISORY_TOPIC_PREFIX

Method Summary

static Destination	getAgentDestination() Returns the agent topic which is used to send commands to the broker
static ActiveMQTopic	getConnectionAdvisoryTopic()
static ActiveMQTopic	getConsumerAdvisoryTopic(ActiveMQDestination destination)
static ActiveMQTopic	getDestinationAdvisoryTopic(ActiveMQDestination destination)
static ActiveMQTopic	getExpiredMessageTopic(ActiveMQDestination destination)
static ActiveMQTopic	getExpiredQueueMessageAdvisoryTopic(ActiveMQDestination destination)
static ActiveMQTopic	getExpiredTopicMessageAdvisoryTopic(ActiveMQDestination destination)
static ActiveMQTopic	getFastProducerAdvisoryTopic(ActiveMQDestination destination)
static ActiveMQTopic	getFullAdvisoryTopic(ActiveMQDestination destination)
static ActiveMQTopic	getMasterBrokerAdvisoryTopic()
static ActiveMQTopic	getMessageConsumedAdvisoryTopic(ActiveMQDestination destination)
static ActiveMQTopic	getMessageDeliveredAdvisoryTopic(ActiveMQDestination destination)
static ActiveMQTopic	getMessageDiscardedAdvisoryTopic(ActiveMQDestination destination)
static ActiveMQTopic	getNoQueueConsumersAdvisoryTopic(ActiveMQDestination destination)
static ActiveMQTopic	getNoTopicConsumersAdvisoryTopic(ActiveMQDestination destination)
static ActiveMQTopic	getProducerAdvisoryTopic(ActiveMQDestination destination)
static ActiveMQTopic	getSlowConsumerAdvisoryTopic(ActiveMQDestination destination)
static boolean	isAdvisoryTopic(ActiveMQDestination destination)
static boolean	isConnectionAdvisoryTopic(ActiveMQDestination destination)
static boolean	isConsumerAdvisoryTopic(ActiveMQDestination destination)
static boolean	isDestinationAdvisoryTopic(ActiveMQDestination destination)
static boolean	isFastProducerAdvisoryTopic(ActiveMQDestination destination)
static boolean	isFullAdvisoryTopic(ActiveMQDestination destination)
static boolean	isMasterBrokerAdvisoryTopic(ActiveMQDestination destination)
static boolean	isMessageConsumedAdvisoryTopic(ActiveMQDestination destination)
static boolean	isMessageDeliveredAdvisoryTopic(ActiveMQDestination destination)
static boolean	isMessageDiscardedAdvisoryTopic(ActiveMQDestination destination)
static boolean	isProducerAdvisoryTopic(ActiveMQDestination destination)
static boolean	isSlowConsumerAdvisoryTopic(ActiveMQDestination destination)

Methods inherited from class java.lang.Object

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

Field Detail

ADVISORY_TOPIC_PREFIX

public static final String ADVISORY_TOPIC_PREFIX

See Also:

Constant Field Values

CONNECTION_ADVISORY_TOPIC

public static final ActiveMQTopic CONNECTION_ADVISORY_TOPIC

QUEUE_ADVISORY_TOPIC

public static final ActiveMQTopic QUEUE_ADVISORY_TOPIC

TOPIC_ADVISORY_TOPIC

public static final ActiveMQTopic TOPIC_ADVISORY_TOPIC

TEMP_QUEUE_ADVISORY_TOPIC

public static final ActiveMQTopic TEMP_QUEUE_ADVISORY_TOPIC

TEMP_TOPIC_ADVISORY_TOPIC

public static final ActiveMQTopic TEMP_TOPIC_ADVISORY_TOPIC

PRODUCER_ADVISORY_TOPIC_PREFIX

public static final String PRODUCER_ADVISORY_TOPIC_PREFIX

See Also:

Constant Field Values

QUEUE_PRODUCER_ADVISORY_TOPIC_PREFIX

public static final String QUEUE_PRODUCER_ADVISORY_TOPIC_PREFIX

See Also:

Constant Field Values

TOPIC_PRODUCER_ADVISORY_TOPIC_PREFIX

public static final String TOPIC_PRODUCER_ADVISORY_TOPIC_PREFIX

See Also:

Constant Field Values

CONSUMER_ADVISORY_TOPIC_PREFIX

public static final String CONSUMER_ADVISORY_TOPIC_PREFIX

See Also:

Constant Field Values

QUEUE_CONSUMER_ADVISORY_TOPIC_PREFIX

public static final String QUEUE_CONSUMER_ADVISORY_TOPIC_PREFIX

See Also:

Constant Field Values

TOPIC_CONSUMER_ADVISORY_TOPIC_PREFIX

public static final String TOPIC_CONSUMER_ADVISORY_TOPIC_PREFIX

See Also:

Constant Field Values

EXPIRED_TOPIC_MESSAGES_TOPIC_PREFIX

public static final String EXPIRED_TOPIC_MESSAGES_TOPIC_PREFIX

See Also:

Constant Field Values

EXPIRED_QUEUE_MESSAGES_TOPIC_PREFIX

public static final String EXPIRED_QUEUE_MESSAGES_TOPIC_PREFIX

See Also:

Constant Field Values

NO_TOPIC_CONSUMERS_TOPIC_PREFIX

public static final String NO_TOPIC_CONSUMERS_TOPIC_PREFIX

See Also:

Constant Field Values

NO_QUEUE_CONSUMERS_TOPIC_PREFIX

public static final String NO_QUEUE_CONSUMERS_TOPIC_PREFIX

See Also:

Constant Field Values

SLOW_CONSUMER_TOPIC_PREFIX

public static final String SLOW_CONSUMER_TOPIC_PREFIX

See Also:

Constant Field Values

FAST_PRODUCER_TOPIC_PREFIX

public static final String FAST_PRODUCER_TOPIC_PREFIX

See Also:

Constant Field Values

MESSAGE_DISCAREDED_TOPIC_PREFIX

public static final String MESSAGE_DISCAREDED_TOPIC_PREFIX

See Also:

Constant Field Values

FULL_TOPIC_PREFIX

public static final String FULL_TOPIC_PREFIX

See Also:

Constant Field Values

MESSAGE_DELIVERED_TOPIC_PREFIX

public static final String MESSAGE_DELIVERED_TOPIC_PREFIX

See Also:

Constant Field Values

MESSAGE_CONSUMED_TOPIC_PREFIX

public static final String MESSAGE_CONSUMED_TOPIC_PREFIX

See Also:

Constant Field Values

MASTER_BROKER_TOPIC_PREFIX

public static final String MASTER_BROKER_TOPIC_PREFIX

See Also:

Constant Field Values

AGENT_TOPIC

public static final String AGENT_TOPIC

See Also:

Constant Field Values

ADIVSORY_MESSAGE_TYPE

public static final String ADIVSORY_MESSAGE_TYPE

See Also:

Constant Field Values

MSG_PROPERTY_ORIGIN_BROKER_ID

public static final String MSG_PROPERTY_ORIGIN_BROKER_ID

See Also:

Constant Field Values

MSG_PROPERTY_ORIGIN_BROKER_NAME

public static final String MSG_PROPERTY_ORIGIN_BROKER_NAME

See Also:

Constant Field Values

MSG_PROPERTY_ORIGIN_BROKER_URL

public static final String MSG_PROPERTY_ORIGIN_BROKER_URL

See Also:

Constant Field Values

MSG_PROPERTY_USAGE_NAME

public static final String MSG_PROPERTY_USAGE_NAME

See Also:

Constant Field Values

MSG_PROPERTY_CONSUMER_ID

public static final String MSG_PROPERTY_CONSUMER_ID

See Also:

Constant Field Values

MSG_PROPERTY_PRODUCER_ID

public static final String MSG_PROPERTY_PRODUCER_ID

See Also:

Constant Field Values

MSG_PROPERTY_MESSAGE_ID

public static final String MSG_PROPERTY_MESSAGE_ID

See Also:

Constant Field Values

TEMP_DESTINATION_COMPOSITE_ADVISORY_TOPIC

public static final ActiveMQTopic TEMP_DESTINATION_COMPOSITE_ADVISORY_TOPIC

Method Detail

getConnectionAdvisoryTopic

public static ActiveMQTopic getConnectionAdvisoryTopic()

getConsumerAdvisoryTopic

public static ActiveMQTopic getConsumerAdvisoryTopic(ActiveMQDestination destination)

getProducerAdvisoryTopic

public static ActiveMQTopic getProducerAdvisoryTopic(ActiveMQDestination destination)

getExpiredMessageTopic

public static ActiveMQTopic getExpiredMessageTopic(ActiveMQDestination destination)

getExpiredTopicMessageAdvisoryTopic

public static ActiveMQTopic getExpiredTopicMessageAdvisoryTopic(ActiveMQDestination destination)

getExpiredQueueMessageAdvisoryTopic

public static ActiveMQTopic getExpiredQueueMessageAdvisoryTopic(ActiveMQDestination destination)

getNoTopicConsumersAdvisoryTopic

public static ActiveMQTopic getNoTopicConsumersAdvisoryTopic(ActiveMQDestination destination)

getNoQueueConsumersAdvisoryTopic

public static ActiveMQTopic getNoQueueConsumersAdvisoryTopic(ActiveMQDestination destination)

getSlowConsumerAdvisoryTopic

public static ActiveMQTopic getSlowConsumerAdvisoryTopic(ActiveMQDestination destination)

getFastProducerAdvisoryTopic

public static ActiveMQTopic getFastProducerAdvisoryTopic(ActiveMQDestination destination)

getMessageDiscardedAdvisoryTopic

public static ActiveMQTopic getMessageDiscardedAdvisoryTopic(ActiveMQDestination destination)

getMessageDeliveredAdvisoryTopic

public static ActiveMQTopic getMessageDeliveredAdvisoryTopic(ActiveMQDestination destination)

getMessageConsumedAdvisoryTopic

public static ActiveMQTopic getMessageConsumedAdvisoryTopic(ActiveMQDestination destination)

getMasterBrokerAdvisoryTopic

public static ActiveMQTopic getMasterBrokerAdvisoryTopic()

getFullAdvisoryTopic

public static ActiveMQTopic getFullAdvisoryTopic(ActiveMQDestination destination)

getDestinationAdvisoryTopic

public static ActiveMQTopic getDestinationAdvisoryTopic(ActiveMQDestination destination)

isDestinationAdvisoryTopic

public static boolean isDestinationAdvisoryTopic(ActiveMQDestination destination)

isAdvisoryTopic

public static boolean isAdvisoryTopic(ActiveMQDestination destination)

isConnectionAdvisoryTopic

public static boolean isConnectionAdvisoryTopic(ActiveMQDestination destination)

isProducerAdvisoryTopic

public static boolean isProducerAdvisoryTopic(ActiveMQDestination destination)

isConsumerAdvisoryTopic

public static boolean isConsumerAdvisoryTopic(ActiveMQDestination destination)

isSlowConsumerAdvisoryTopic

public static boolean isSlowConsumerAdvisoryTopic(ActiveMQDestination destination)

isFastProducerAdvisoryTopic

public static boolean isFastProducerAdvisoryTopic(ActiveMQDestination destination)

isMessageConsumedAdvisoryTopic

public static boolean isMessageConsumedAdvisoryTopic(ActiveMQDestination destination)

isMasterBrokerAdvisoryTopic

public static boolean isMasterBrokerAdvisoryTopic(ActiveMQDestination destination)

isMessageDeliveredAdvisoryTopic

public static boolean isMessageDeliveredAdvisoryTopic(ActiveMQDestination destination)

isMessageDiscardedAdvisoryTopic

public static boolean isMessageDiscardedAdvisoryTopic(ActiveMQDestination destination)

isFullAdvisoryTopic

public static boolean isFullAdvisoryTopic(ActiveMQDestination destination)

getAgentDestination

public static Destination getAgentDestination()

Returns the agent topic which is used to send commands to the broker