Package org.apache.activemq.advisory
Class AdvisorySupport
- java.lang.Object
-
- org.apache.activemq.advisory.AdvisorySupport
-
public final class AdvisorySupport extends Object
-
-
Field Summary
-
Method Summary
-
-
-
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
-
ANONYMOUS_PRODUCER_ADVISORY_TOPIC_PREFIX
public static final String ANONYMOUS_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
-
VIRTUAL_DESTINATION_CONSUMER_ADVISORY_TOPIC_PREFIX
public static final String VIRTUAL_DESTINATION_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
-
QUEUE_VIRTUAL_DESTINATION_CONSUMER_ADVISORY_TOPIC_PREFIX
public static final String QUEUE_VIRTUAL_DESTINATION_CONSUMER_ADVISORY_TOPIC_PREFIX
- See Also:
- Constant Field Values
-
TOPIC_VIRTUAL_DESTINATION_CONSUMER_ADVISORY_TOPIC_PREFIX
public static final String TOPIC_VIRTUAL_DESTINATION_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_USAGE_COUNT
public static final String MSG_PROPERTY_USAGE_COUNT
- 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_DESTINATION
public static final String MSG_PROPERTY_DESTINATION
- 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)
-
getVirtualDestinationConsumerAdvisoryTopic
public static ActiveMQTopic getVirtualDestinationConsumerAdvisoryTopic(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)
-
isVirtualDestinationConsumerAdvisoryTopic
public static boolean isVirtualDestinationConsumerAdvisoryTopic(Destination destination) throws JMSException
- Throws:
JMSException
-
isVirtualDestinationConsumerAdvisoryTopic
public static boolean isVirtualDestinationConsumerAdvisoryTopic(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()
-
-