AdvisorySupport.h

Go to the documentation of this file.

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#ifndef _ACTIVEMQ_UTIL_ADVISORYSUPPORT_H_
#define _ACTIVEMQ_UTIL_ADVISORYSUPPORT_H_

#include <activemq/util/Config.h>

#include <string>
#include <vector>

namespace cms {
    class Destination;
}
namespace activemq {
namespace commands {
    class ActiveMQDestination;
}
namespace util {

    class AMQCPP_API AdvisorySupport {
    private:

        AdvisorySupport();

    public:

        static const std::string ADVISORY_TOPIC_PREFIX;
        static const std::string PRODUCER_ADVISORY_TOPIC_PREFIX;
        static const std::string QUEUE_PRODUCER_ADVISORY_TOPIC_PREFIX;
        static const std::string TOPIC_PRODUCER_ADVISORY_TOPIC_PREFIX;
        static const std::string CONSUMER_ADVISORY_TOPIC_PREFIX;
        static const std::string QUEUE_CONSUMER_ADVISORY_TOPIC_PREFIX;
        static const std::string TOPIC_CONSUMER_ADVISORY_TOPIC_PREFIX;
        static const std::string EXPIRED_TOPIC_MESSAGES_TOPIC_PREFIX;
        static const std::string EXPIRED_QUEUE_MESSAGES_TOPIC_PREFIX;
        static const std::string NO_TOPIC_CONSUMERS_TOPIC_PREFIX;
        static const std::string NO_QUEUE_CONSUMERS_TOPIC_PREFIX;
        static const std::string SLOW_CONSUMER_TOPIC_PREFIX;
        static const std::string FAST_PRODUCER_TOPIC_PREFIX;
        static const std::string MESSAGE_DISCAREDED_TOPIC_PREFIX;
        static const std::string FULL_TOPIC_PREFIX;
        static const std::string MESSAGE_DELIVERED_TOPIC_PREFIX;
        static const std::string MESSAGE_CONSUMED_TOPIC_PREFIX;
        static const std::string MESSAGE_DLQ_TOPIC_PREFIX;
        static const std::string MASTER_BROKER_TOPIC_PREFIX;
        static const std::string NETWORK_BRIDGE_TOPIC_PREFIX;
        static const std::string AGENT_TOPIC;
        static const std::string ADIVSORY_MESSAGE_TYPE;
        static const std::string MSG_PROPERTY_ORIGIN_BROKER_ID;
        static const std::string MSG_PROPERTY_ORIGIN_BROKER_NAME;
        static const std::string MSG_PROPERTY_ORIGIN_BROKER_URL;
        static const std::string MSG_PROPERTY_USAGE_NAME;
        static const std::string MSG_PROPERTY_CONSUMER_ID;
        static const std::string MSG_PROPERTY_PRODUCER_ID;
        static const std::string MSG_PROPERTY_MESSAGE_ID;
        static const std::string MSG_PROPERTY_CONSUMER_COUNT;
        static const std::string MSG_PROPERTY_DISCARDED_COUNT;

    public:

        ~AdvisorySupport();

    public:

        static commands::ActiveMQDestination* getTempDestinationCompositeAdvisoryTopic();

        static commands::ActiveMQDestination* getAllDestinationsCompositeAdvisoryTopic();

        static std::vector<commands::ActiveMQDestination*> getAllDestinationAdvisoryTopics(const cms::Destination* destination);

        static std::vector<commands::ActiveMQDestination*> getAllDestinationAdvisoryTopics(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getConnectionAdvisoryTopic();

        static commands::ActiveMQDestination* getQueueAdvisoryTopic();

        static commands::ActiveMQDestination* getTopicAdvisoryTopic();

        static commands::ActiveMQDestination* getTempQueueAdvisoryTopic();

        static commands::ActiveMQDestination* getTempTopicAdvisoryTopic();

        static commands::ActiveMQDestination* getConsumerAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getConsumerAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getProducerAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getProducerAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getExpiredMessageTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getExpiredMessageTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getExpiredTopicMessageAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getExpiredTopicMessageAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getExpiredQueueMessageAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getExpiredQueueMessageAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getNoConsumersAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getNoConsumersAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getNoTopicConsumersAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getNoTopicConsumersAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getNoQueueConsumersAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getNoQueueConsumersAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getSlowConsumerAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getSlowConsumerAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getFastProducerAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getFastProducerAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getMessageDiscardedAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getMessageDiscardedAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getMessageDeliveredAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getMessageDeliveredAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getMessageConsumedAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getMessageConsumedAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getMessageDLQdAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getMessageDLQdAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getMasterBrokerAdvisoryTopic();

        static commands::ActiveMQDestination* getNetworkBridgeAdvisoryTopic();

        static commands::ActiveMQDestination* getFullAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getFullAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static commands::ActiveMQDestination* getDestinationAdvisoryTopic(const cms::Destination* destination);

        static commands::ActiveMQDestination* getDestinationAdvisoryTopic(const commands::ActiveMQDestination* destination);

    public:

        static bool isDestinationAdvisoryTopic(const cms::Destination* destination);

        static bool isDestinationAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isTempDestinationAdvisoryTopic(const cms::Destination* destination);

        static bool isTempDestinationAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isAdvisoryTopic(const cms::Destination* destination);

        static bool isAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isConnectionAdvisoryTopic(const cms::Destination* destination);

        static bool isConnectionAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isProducerAdvisoryTopic(const cms::Destination* destination);

        static bool isProducerAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isConsumerAdvisoryTopic(const cms::Destination* destination);

        static bool isConsumerAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isSlowConsumerAdvisoryTopic(const cms::Destination* destination);

        static bool isSlowConsumerAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isFastProducerAdvisoryTopic(const cms::Destination* destination);

        static bool isFastProducerAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isMessageConsumedAdvisoryTopic(const cms::Destination* destination);

        static bool isMessageConsumedAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isMasterBrokerAdvisoryTopic(const cms::Destination* destination);

        static bool isMasterBrokerAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isMessageDeliveredAdvisoryTopic(const cms::Destination* destination);

        static bool isMessageDeliveredAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isMessageDiscardedAdvisoryTopic(const cms::Destination* destination);

        static bool isMessageDiscardedAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isMessageDLQdAdvisoryTopic(const cms::Destination* destination);

        static bool isMessageDLQdAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isFullAdvisoryTopic(const cms::Destination* destination);

        static bool isFullAdvisoryTopic(const commands::ActiveMQDestination* destination);

        static bool isNetworkBridgeAdvisoryTopic(const cms::Destination* destination);

        static bool isNetworkBridgeAdvisoryTopic(const commands::ActiveMQDestination* destination);

    };

}}

#endif /* _ACTIVEMQ_UTIL_ADVISORYSUPPORT_H_ */