18#ifndef _ACTIVEMQ_UTIL_ADVISORYSUPPORT_H_
19#define _ACTIVEMQ_UTIL_ADVISORYSUPPORT_H_
#define AMQCPP_API
Definition Config.h:30
Definition ActiveMQDestination.h:39
static commands::ActiveMQDestination * getMessageDeliveredAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages when a message is dispatc...
static const std::string ADVISORY_TOPIC_PREFIX
Definition AdvisorySupport.h:48
static commands::ActiveMQDestination * getDestinationAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for events related to Des...
static commands::ActiveMQDestination * getSlowConsumerAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for slow consumers of mes...
static commands::ActiveMQDestination * getMasterBrokerAdvisoryTopic()
Returns a new Pointer to an Destination that will consume advisory messages for Master Brokers.
static commands::ActiveMQDestination * getNoQueueConsumersAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for no consumer events fo...
static bool isProducerAdvisoryTopic(const commands::ActiveMQDestination *destination)
static const std::string MESSAGE_DLQ_TOPIC_PREFIX
Definition AdvisorySupport.h:65
static commands::ActiveMQDestination * getTempDestinationCompositeAdvisoryTopic()
Returns a new Pointer to an Destination that will consume the advisory messages for both Temporary To...
static std::vector< commands::ActiveMQDestination * > getAllDestinationAdvisoryTopics(const commands::ActiveMQDestination *destination)
Returns a new vector that contains pointers to all the available advisory topics for the given destin...
static bool isConnectionAdvisoryTopic(const cms::Destination *destination)
static commands::ActiveMQDestination * getTempQueueAdvisoryTopic()
Returns a new Pointer to an Destination that will consume advisory messages for Temporary Queues.
static commands::ActiveMQDestination * getNoQueueConsumersAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for no consumer events fo...
static bool isFastProducerAdvisoryTopic(const commands::ActiveMQDestination *destination)
static const std::string CONSUMER_ADVISORY_TOPIC_PREFIX
Definition AdvisorySupport.h:52
static commands::ActiveMQDestination * getConnectionAdvisoryTopic()
Returns a new Pointer to an Destination that will consume advisory messages for Connections.
static bool isMessageDeliveredAdvisoryTopic(const commands::ActiveMQDestination *destination)
static bool isNetworkBridgeAdvisoryTopic(const cms::Destination *destination)
static commands::ActiveMQDestination * getProducerAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for Producer events.
static commands::ActiveMQDestination * getMessageDeliveredAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages when a message is dispatc...
static bool isAdvisoryTopic(const cms::Destination *destination)
static const std::string MSG_PROPERTY_ORIGIN_BROKER_NAME
Definition AdvisorySupport.h:71
static commands::ActiveMQDestination * getExpiredTopicMessageAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for expiration events for...
static commands::ActiveMQDestination * getTempTopicAdvisoryTopic()
Returns a new Pointer to an Destination that will consume advisory messages for Temporary Topics.
static bool isDestinationAdvisoryTopic(const commands::ActiveMQDestination *destination)
static commands::ActiveMQDestination * getNetworkBridgeAdvisoryTopic()
Returns a new Pointer to an Destination that will consume advisory messages for Network Bridges.
static commands::ActiveMQDestination * getDestinationAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for events related to Des...
static bool isMasterBrokerAdvisoryTopic(const commands::ActiveMQDestination *destination)
static commands::ActiveMQDestination * getNoConsumersAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for no consumer events fo...
static commands::ActiveMQDestination * getSlowConsumerAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for slow consumers of mes...
static commands::ActiveMQDestination * getNoTopicConsumersAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for no consumer events fo...
static const std::string QUEUE_CONSUMER_ADVISORY_TOPIC_PREFIX
Definition AdvisorySupport.h:53
static const std::string MSG_PROPERTY_MESSAGE_ID
Definition AdvisorySupport.h:76
static commands::ActiveMQDestination * getFastProducerAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for fast producers of mes...
static commands::ActiveMQDestination * getMessageConsumedAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages when a message is consume...
static const std::string PRODUCER_ADVISORY_TOPIC_PREFIX
Definition AdvisorySupport.h:49
static bool isTempDestinationAdvisoryTopic(const cms::Destination *destination)
static bool isAdvisoryTopic(const commands::ActiveMQDestination *destination)
static bool isTempDestinationAdvisoryTopic(const commands::ActiveMQDestination *destination)
static bool isMessageDeliveredAdvisoryTopic(const cms::Destination *destination)
static const std::string ADIVSORY_MESSAGE_TYPE
Definition AdvisorySupport.h:69
static const std::string FULL_TOPIC_PREFIX
Definition AdvisorySupport.h:62
static commands::ActiveMQDestination * getFullAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages when the given destinatio...
static bool isMasterBrokerAdvisoryTopic(const cms::Destination *destination)
static const std::string MSG_PROPERTY_PRODUCER_ID
Definition AdvisorySupport.h:75
static bool isConsumerAdvisoryTopic(const cms::Destination *destination)
static bool isSlowConsumerAdvisoryTopic(const cms::Destination *destination)
static const std::string MSG_PROPERTY_ORIGIN_BROKER_ID
Definition AdvisorySupport.h:70
static commands::ActiveMQDestination * getExpiredMessageTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for expiration events for...
static bool isFullAdvisoryTopic(const commands::ActiveMQDestination *destination)
static bool isMessageConsumedAdvisoryTopic(const commands::ActiveMQDestination *destination)
static bool isFullAdvisoryTopic(const cms::Destination *destination)
static bool isMessageDLQdAdvisoryTopic(const cms::Destination *destination)
static const std::string EXPIRED_TOPIC_MESSAGES_TOPIC_PREFIX
Definition AdvisorySupport.h:55
static const std::string MSG_PROPERTY_CONSUMER_ID
Definition AdvisorySupport.h:74
static bool isSlowConsumerAdvisoryTopic(const commands::ActiveMQDestination *destination)
static const std::string SLOW_CONSUMER_TOPIC_PREFIX
Definition AdvisorySupport.h:59
static commands::ActiveMQDestination * getMessageConsumedAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages when a message is consume...
static const std::string NO_QUEUE_CONSUMERS_TOPIC_PREFIX
Definition AdvisorySupport.h:58
static std::vector< commands::ActiveMQDestination * > getAllDestinationAdvisoryTopics(const cms::Destination *destination)
Returns a new vector that contains pointers to all the available advisory topics for the given destin...
static bool isConsumerAdvisoryTopic(const commands::ActiveMQDestination *destination)
static commands::ActiveMQDestination * getExpiredMessageTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for expiration events for...
static const std::string TOPIC_PRODUCER_ADVISORY_TOPIC_PREFIX
Definition AdvisorySupport.h:51
static const std::string MESSAGE_CONSUMED_TOPIC_PREFIX
Definition AdvisorySupport.h:64
static commands::ActiveMQDestination * getConsumerAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for Consumer events.
static const std::string MSG_PROPERTY_DISCARDED_COUNT
Definition AdvisorySupport.h:78
static commands::ActiveMQDestination * getMessageDiscardedAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages when a message is discard...
static commands::ActiveMQDestination * getNoTopicConsumersAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for no consumer events fo...
static bool isFastProducerAdvisoryTopic(const cms::Destination *destination)
static const std::string QUEUE_PRODUCER_ADVISORY_TOPIC_PREFIX
Definition AdvisorySupport.h:50
static commands::ActiveMQDestination * getQueueAdvisoryTopic()
Returns a new Pointer to an Destination that will consume advisory messages for Queues.
static commands::ActiveMQDestination * getFastProducerAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for fast producers of mes...
static bool isProducerAdvisoryTopic(const cms::Destination *destination)
static commands::ActiveMQDestination * getProducerAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for Producer events.
static const std::string MASTER_BROKER_TOPIC_PREFIX
Definition AdvisorySupport.h:66
static commands::ActiveMQDestination * getAllDestinationsCompositeAdvisoryTopic()
Returns a new Pointer to an Destination that will consume the advisory messages for all Destinations ...
static const std::string NETWORK_BRIDGE_TOPIC_PREFIX
Definition AdvisorySupport.h:67
static commands::ActiveMQDestination * getNoConsumersAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for no consumer events fo...
static const std::string MESSAGE_DISCAREDED_TOPIC_PREFIX
Definition AdvisorySupport.h:61
static const std::string MSG_PROPERTY_CONSUMER_COUNT
Definition AdvisorySupport.h:77
static bool isNetworkBridgeAdvisoryTopic(const commands::ActiveMQDestination *destination)
static commands::ActiveMQDestination * getExpiredQueueMessageAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for expiration events for...
static const std::string MSG_PROPERTY_ORIGIN_BROKER_URL
Definition AdvisorySupport.h:72
static const std::string NO_TOPIC_CONSUMERS_TOPIC_PREFIX
Definition AdvisorySupport.h:57
static commands::ActiveMQDestination * getExpiredQueueMessageAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for expiration events for...
static bool isConnectionAdvisoryTopic(const commands::ActiveMQDestination *destination)
static commands::ActiveMQDestination * getTopicAdvisoryTopic()
Returns a new Pointer to an Destination that will consume advisory messages for Topics.
static const std::string FAST_PRODUCER_TOPIC_PREFIX
Definition AdvisorySupport.h:60
static commands::ActiveMQDestination * getFullAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages when the given destinatio...
static const std::string TOPIC_CONSUMER_ADVISORY_TOPIC_PREFIX
Definition AdvisorySupport.h:54
static bool isMessageDLQdAdvisoryTopic(const commands::ActiveMQDestination *destination)
static commands::ActiveMQDestination * getConsumerAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for Consumer events.
static bool isDestinationAdvisoryTopic(const cms::Destination *destination)
static bool isMessageConsumedAdvisoryTopic(const cms::Destination *destination)
static commands::ActiveMQDestination * getMessageDiscardedAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages when a message is discard...
static bool isMessageDiscardedAdvisoryTopic(const commands::ActiveMQDestination *destination)
static commands::ActiveMQDestination * getMessageDLQdAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages when a message is sent to...
static const std::string EXPIRED_QUEUE_MESSAGES_TOPIC_PREFIX
Definition AdvisorySupport.h:56
static commands::ActiveMQDestination * getExpiredTopicMessageAdvisoryTopic(const commands::ActiveMQDestination *destination)
Returns a new Pointer to an Destination that will consume advisory messages for expiration events for...
static commands::ActiveMQDestination * getMessageDLQdAdvisoryTopic(const cms::Destination *destination)
Returns a new Pointer to an Destination that will consume advisory messages when a message is sent to...
static const std::string MSG_PROPERTY_USAGE_NAME
Definition AdvisorySupport.h:73
static const std::string AGENT_TOPIC
Definition AdvisorySupport.h:68
static bool isMessageDiscardedAdvisoryTopic(const cms::Destination *destination)
static const std::string MESSAGE_DELIVERED_TOPIC_PREFIX
Definition AdvisorySupport.h:63
A Destination object encapsulates a provider-specific address.
Definition Destination.h:39
Definition ActiveMQBlobMessage.h:28
Definition ActiveMQMessageTransformation.h:36
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition DestinationResolver.h:23