org.apache.activemq.advisory
Class AdvisorySupport

java.lang.Object
  extended by 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 ALL_DESTINATIONS_COMPOSITE_ADVISORY_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 MESSAGE_DLQ_TOPIC_PREFIX
           
static String MSG_PROPERTY_CONSUMER_COUNT
           
static String MSG_PROPERTY_CONSUMER_ID
           
static String MSG_PROPERTY_DISCARDED_COUNT
           
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 NETWORK_BRIDGE_FORWARD_FAILURE_TOPIC_PREFIX
           
static String NETWORK_BRIDGE_TOPIC_PREFIX
           
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[] getAllDestinationAdvisoryTopics(ActiveMQDestination destination)
           
static ActiveMQTopic[] getAllDestinationAdvisoryTopics(Destination destination)
           
static ActiveMQTopic getConnectionAdvisoryTopic()
           
static ActiveMQTopic getConsumerAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getConsumerAdvisoryTopic(Destination destination)
           
static ActiveMQTopic getDestinationAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getDestinationAdvisoryTopic(Destination destination)
           
static ActiveMQTopic getExpiredMessageTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getExpiredMessageTopic(Destination destination)
           
static ActiveMQTopic getExpiredQueueMessageAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getExpiredQueueMessageAdvisoryTopic(Destination destination)
           
static ActiveMQTopic getExpiredTopicMessageAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getFastProducerAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getFastProducerAdvisoryTopic(Destination destination)
           
static ActiveMQTopic getFullAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getFullAdvisoryTopic(Destination destination)
           
static ActiveMQTopic getMasterBrokerAdvisoryTopic()
           
static ActiveMQTopic getMessageConsumedAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getMessageConsumedAdvisoryTopic(Destination destination)
           
static ActiveMQTopic getMessageDeliveredAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getMessageDeliveredAdvisoryTopic(Destination destination)
           
static ActiveMQTopic getMessageDiscardedAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getMessageDiscardedAdvisoryTopic(Destination destination)
           
static ActiveMQTopic getMessageDLQdAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getNetworkBridgeAdvisoryTopic()
           
static ActiveMQTopic getNetworkBridgeForwardFailureAdvisoryTopic()
           
static ActiveMQTopic getNoConsumersAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getNoConsumersAdvisoryTopic(Destination destination)
           
static ActiveMQTopic getNoQueueConsumersAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getNoQueueConsumersAdvisoryTopic(Destination destination)
           
static ActiveMQTopic getNoTopicConsumersAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getNoTopicConsumersAdvisoryTopic(Destination destination)
           
static ActiveMQTopic getProducerAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getProducerAdvisoryTopic(Destination destination)
           
static ActiveMQTopic getSlowConsumerAdvisoryTopic(ActiveMQDestination destination)
           
static ActiveMQTopic getSlowConsumerAdvisoryTopic(Destination destination)
           
static boolean isAdvisoryTopic(ActiveMQDestination destination)
           
static boolean isAdvisoryTopic(Destination destination)
           
static boolean isConnectionAdvisoryTopic(ActiveMQDestination destination)
           
static boolean isConnectionAdvisoryTopic(Destination destination)
           
static boolean isConsumerAdvisoryTopic(ActiveMQDestination destination)
           
static boolean isConsumerAdvisoryTopic(Destination destination)
           
static boolean isDestinationAdvisoryTopic(ActiveMQDestination destination)
           
static boolean isDestinationAdvisoryTopic(Destination destination)
           
static boolean isFastProducerAdvisoryTopic(ActiveMQDestination destination)
           
static boolean isFastProducerAdvisoryTopic(Destination destination)
           
static boolean isFullAdvisoryTopic(ActiveMQDestination destination)
           
static boolean isFullAdvisoryTopic(Destination destination)
           
static boolean isMasterBrokerAdvisoryTopic(ActiveMQDestination destination)
           
static boolean isMasterBrokerAdvisoryTopic(Destination destination)
           
static boolean isMessageConsumedAdvisoryTopic(ActiveMQDestination destination)
           
static boolean isMessageConsumedAdvisoryTopic(Destination destination)
           
static boolean isMessageDeliveredAdvisoryTopic(ActiveMQDestination destination)
           
static boolean isMessageDeliveredAdvisoryTopic(Destination destination)
           
static boolean isMessageDiscardedAdvisoryTopic(ActiveMQDestination destination)
           
static boolean isMessageDiscardedAdvisoryTopic(Destination destination)
           
static boolean isNetworkBridgeAdvisoryTopic(ActiveMQDestination destination)
           
static boolean isNetworkBridgeAdvisoryTopic(Destination destination)
           
static boolean isProducerAdvisoryTopic(ActiveMQDestination destination)
           
static boolean isProducerAdvisoryTopic(Destination destination)
           
static boolean isSlowConsumerAdvisoryTopic(ActiveMQDestination destination)
           
static boolean isSlowConsumerAdvisoryTopic(Destination destination)
           
static boolean isTempDestinationAdvisoryTopic(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

MESSAGE_DLQ_TOPIC_PREFIX

public static final String MESSAGE_DLQ_TOPIC_PREFIX
See Also:
Constant Field Values

MASTER_BROKER_TOPIC_PREFIX

public static final String MASTER_BROKER_TOPIC_PREFIX
See Also:
Constant Field Values

NETWORK_BRIDGE_TOPIC_PREFIX

public static final String NETWORK_BRIDGE_TOPIC_PREFIX
See Also:
Constant Field Values

NETWORK_BRIDGE_FORWARD_FAILURE_TOPIC_PREFIX

public static final String NETWORK_BRIDGE_FORWARD_FAILURE_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

MSG_PROPERTY_CONSUMER_COUNT

public static final String MSG_PROPERTY_CONSUMER_COUNT
See Also:
Constant Field Values

MSG_PROPERTY_DISCARDED_COUNT

public static final String MSG_PROPERTY_DISCARDED_COUNT
See Also:
Constant Field Values

ALL_DESTINATIONS_COMPOSITE_ADVISORY_TOPIC

public static final ActiveMQTopic ALL_DESTINATIONS_COMPOSITE_ADVISORY_TOPIC

TEMP_DESTINATION_COMPOSITE_ADVISORY_TOPIC

public static final ActiveMQTopic TEMP_DESTINATION_COMPOSITE_ADVISORY_TOPIC
Method Detail

getConnectionAdvisoryTopic

public static ActiveMQTopic getConnectionAdvisoryTopic()

getAllDestinationAdvisoryTopics

public static ActiveMQTopic[] getAllDestinationAdvisoryTopics(Destination destination)
                                                       throws JMSException
Throws:
JMSException

getAllDestinationAdvisoryTopics

public static ActiveMQTopic[] getAllDestinationAdvisoryTopics(ActiveMQDestination destination)
                                                       throws JMSException
Throws:
JMSException

getConsumerAdvisoryTopic

public static ActiveMQTopic getConsumerAdvisoryTopic(Destination destination)
                                              throws JMSException
Throws:
JMSException

getConsumerAdvisoryTopic

public static ActiveMQTopic getConsumerAdvisoryTopic(ActiveMQDestination destination)

getProducerAdvisoryTopic

public static ActiveMQTopic getProducerAdvisoryTopic(Destination destination)
                                              throws JMSException
Throws:
JMSException

getProducerAdvisoryTopic

public static ActiveMQTopic getProducerAdvisoryTopic(ActiveMQDestination destination)

getExpiredMessageTopic

public static ActiveMQTopic getExpiredMessageTopic(Destination destination)
                                            throws JMSException
Throws:
JMSException

getExpiredMessageTopic

public static ActiveMQTopic getExpiredMessageTopic(ActiveMQDestination destination)

getExpiredTopicMessageAdvisoryTopic

public static ActiveMQTopic getExpiredTopicMessageAdvisoryTopic(ActiveMQDestination destination)

getExpiredQueueMessageAdvisoryTopic

public static ActiveMQTopic getExpiredQueueMessageAdvisoryTopic(Destination destination)
                                                         throws JMSException
Throws:
JMSException

getExpiredQueueMessageAdvisoryTopic

public static ActiveMQTopic getExpiredQueueMessageAdvisoryTopic(ActiveMQDestination destination)

getNoConsumersAdvisoryTopic

public static ActiveMQTopic getNoConsumersAdvisoryTopic(Destination destination)
                                                 throws JMSException
Throws:
JMSException

getNoConsumersAdvisoryTopic

public static ActiveMQTopic getNoConsumersAdvisoryTopic(ActiveMQDestination destination)

getNoTopicConsumersAdvisoryTopic

public static ActiveMQTopic getNoTopicConsumersAdvisoryTopic(Destination destination)
                                                      throws JMSException
Throws:
JMSException

getNoTopicConsumersAdvisoryTopic

public static ActiveMQTopic getNoTopicConsumersAdvisoryTopic(ActiveMQDestination destination)

getNoQueueConsumersAdvisoryTopic

public static ActiveMQTopic getNoQueueConsumersAdvisoryTopic(Destination destination)
                                                      throws JMSException
Throws:
JMSException

getNoQueueConsumersAdvisoryTopic

public static ActiveMQTopic getNoQueueConsumersAdvisoryTopic(ActiveMQDestination destination)

getSlowConsumerAdvisoryTopic

public static ActiveMQTopic getSlowConsumerAdvisoryTopic(Destination destination)
                                                  throws JMSException
Throws:
JMSException

getSlowConsumerAdvisoryTopic

public static ActiveMQTopic getSlowConsumerAdvisoryTopic(ActiveMQDestination destination)

getFastProducerAdvisoryTopic

public static ActiveMQTopic getFastProducerAdvisoryTopic(Destination destination)
                                                  throws JMSException
Throws:
JMSException

getFastProducerAdvisoryTopic

public static ActiveMQTopic getFastProducerAdvisoryTopic(ActiveMQDestination destination)

getMessageDiscardedAdvisoryTopic

public static ActiveMQTopic getMessageDiscardedAdvisoryTopic(Destination destination)
                                                      throws JMSException
Throws:
JMSException

getMessageDiscardedAdvisoryTopic

public static ActiveMQTopic getMessageDiscardedAdvisoryTopic(ActiveMQDestination destination)

getMessageDeliveredAdvisoryTopic

public static ActiveMQTopic getMessageDeliveredAdvisoryTopic(Destination destination)
                                                      throws JMSException
Throws:
JMSException

getMessageDeliveredAdvisoryTopic

public static ActiveMQTopic getMessageDeliveredAdvisoryTopic(ActiveMQDestination destination)

getMessageConsumedAdvisoryTopic

public static ActiveMQTopic getMessageConsumedAdvisoryTopic(Destination destination)
                                                     throws JMSException
Throws:
JMSException

getMessageConsumedAdvisoryTopic

public static ActiveMQTopic getMessageConsumedAdvisoryTopic(ActiveMQDestination destination)

getMessageDLQdAdvisoryTopic

public static ActiveMQTopic getMessageDLQdAdvisoryTopic(ActiveMQDestination destination)

getMasterBrokerAdvisoryTopic

public static ActiveMQTopic getMasterBrokerAdvisoryTopic()

getNetworkBridgeAdvisoryTopic

public static ActiveMQTopic getNetworkBridgeAdvisoryTopic()

getFullAdvisoryTopic

public static ActiveMQTopic getFullAdvisoryTopic(Destination destination)
                                          throws JMSException
Throws:
JMSException

getFullAdvisoryTopic

public static ActiveMQTopic getFullAdvisoryTopic(ActiveMQDestination destination)

getDestinationAdvisoryTopic

public static ActiveMQTopic getDestinationAdvisoryTopic(Destination destination)
                                                 throws JMSException
Throws:
JMSException

getDestinationAdvisoryTopic

public static ActiveMQTopic getDestinationAdvisoryTopic(ActiveMQDestination destination)

isDestinationAdvisoryTopic

public static boolean isDestinationAdvisoryTopic(Destination destination)
                                          throws JMSException
Throws:
JMSException

isTempDestinationAdvisoryTopic

public static boolean isTempDestinationAdvisoryTopic(ActiveMQDestination destination)

isDestinationAdvisoryTopic

public static boolean isDestinationAdvisoryTopic(ActiveMQDestination destination)

isAdvisoryTopic

public static boolean isAdvisoryTopic(Destination destination)
                               throws JMSException
Throws:
JMSException

isAdvisoryTopic

public static boolean isAdvisoryTopic(ActiveMQDestination destination)

isConnectionAdvisoryTopic

public static boolean isConnectionAdvisoryTopic(Destination destination)
                                         throws JMSException
Throws:
JMSException

isConnectionAdvisoryTopic

public static boolean isConnectionAdvisoryTopic(ActiveMQDestination destination)

isProducerAdvisoryTopic

public static boolean isProducerAdvisoryTopic(Destination destination)
                                       throws JMSException
Throws:
JMSException

isProducerAdvisoryTopic

public static boolean isProducerAdvisoryTopic(ActiveMQDestination destination)

isConsumerAdvisoryTopic

public static boolean isConsumerAdvisoryTopic(Destination destination)
                                       throws JMSException
Throws:
JMSException

isConsumerAdvisoryTopic

public static boolean isConsumerAdvisoryTopic(ActiveMQDestination destination)

isSlowConsumerAdvisoryTopic

public static boolean isSlowConsumerAdvisoryTopic(Destination destination)
                                           throws JMSException
Throws:
JMSException

isSlowConsumerAdvisoryTopic

public static boolean isSlowConsumerAdvisoryTopic(ActiveMQDestination destination)

isFastProducerAdvisoryTopic

public static boolean isFastProducerAdvisoryTopic(Destination destination)
                                           throws JMSException
Throws:
JMSException

isFastProducerAdvisoryTopic

public static boolean isFastProducerAdvisoryTopic(ActiveMQDestination destination)

isMessageConsumedAdvisoryTopic

public static boolean isMessageConsumedAdvisoryTopic(Destination destination)
                                              throws JMSException
Throws:
JMSException

isMessageConsumedAdvisoryTopic

public static boolean isMessageConsumedAdvisoryTopic(ActiveMQDestination destination)

isMasterBrokerAdvisoryTopic

public static boolean isMasterBrokerAdvisoryTopic(Destination destination)
                                           throws JMSException
Throws:
JMSException

isMasterBrokerAdvisoryTopic

public static boolean isMasterBrokerAdvisoryTopic(ActiveMQDestination destination)

isMessageDeliveredAdvisoryTopic

public static boolean isMessageDeliveredAdvisoryTopic(Destination destination)
                                               throws JMSException
Throws:
JMSException

isMessageDeliveredAdvisoryTopic

public static boolean isMessageDeliveredAdvisoryTopic(ActiveMQDestination destination)

isMessageDiscardedAdvisoryTopic

public static boolean isMessageDiscardedAdvisoryTopic(Destination destination)
                                               throws JMSException
Throws:
JMSException

isMessageDiscardedAdvisoryTopic

public static boolean isMessageDiscardedAdvisoryTopic(ActiveMQDestination destination)

isFullAdvisoryTopic

public static boolean isFullAdvisoryTopic(Destination destination)
                                   throws JMSException
Throws:
JMSException

isFullAdvisoryTopic

public static boolean isFullAdvisoryTopic(ActiveMQDestination destination)

isNetworkBridgeAdvisoryTopic

public static boolean isNetworkBridgeAdvisoryTopic(Destination destination)
                                            throws JMSException
Throws:
JMSException

isNetworkBridgeAdvisoryTopic

public static boolean isNetworkBridgeAdvisoryTopic(ActiveMQDestination destination)

getAgentDestination

public static Destination getAgentDestination()
Returns the agent topic which is used to send commands to the broker


getNetworkBridgeForwardFailureAdvisoryTopic

public static ActiveMQTopic getNetworkBridgeForwardFailureAdvisoryTopic()


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.