activemq-cpp-3.9.5
AdvisorySupport.h
Go to the documentation of this file.
1/*
2 * Licensed to the Apache Software Foundation (ASF) under one or more
3 * contributor license agreements. See the NOTICE file distributed with
4 * this work for additional information regarding copyright ownership.
5 * The ASF licenses this file to You under the Apache License, Version 2.0
6 * (the "License"); you may not use this file except in compliance with
7 * the License. You may obtain a copy of the License at
8 *
9 * http://www.apache.org/licenses/LICENSE-2.0
10 *
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
16 */
17
18#ifndef _ACTIVEMQ_UTIL_ADVISORYSUPPORT_H_
19#define _ACTIVEMQ_UTIL_ADVISORYSUPPORT_H_
20
22
23#include <string>
24#include <vector>
25
26namespace cms {
27 class Destination;
28}
29namespace activemq {
30namespace commands {
32}
33namespace util {
34
41 class AMQCPP_API AdvisorySupport {
42 private:
43
44 AdvisorySupport();
45
46 public:
47
48 static const std::string ADVISORY_TOPIC_PREFIX;
49 static const std::string PRODUCER_ADVISORY_TOPIC_PREFIX;
50 static const std::string QUEUE_PRODUCER_ADVISORY_TOPIC_PREFIX;
51 static const std::string TOPIC_PRODUCER_ADVISORY_TOPIC_PREFIX;
52 static const std::string CONSUMER_ADVISORY_TOPIC_PREFIX;
53 static const std::string QUEUE_CONSUMER_ADVISORY_TOPIC_PREFIX;
54 static const std::string TOPIC_CONSUMER_ADVISORY_TOPIC_PREFIX;
55 static const std::string EXPIRED_TOPIC_MESSAGES_TOPIC_PREFIX;
56 static const std::string EXPIRED_QUEUE_MESSAGES_TOPIC_PREFIX;
57 static const std::string NO_TOPIC_CONSUMERS_TOPIC_PREFIX;
58 static const std::string NO_QUEUE_CONSUMERS_TOPIC_PREFIX;
59 static const std::string SLOW_CONSUMER_TOPIC_PREFIX;
60 static const std::string FAST_PRODUCER_TOPIC_PREFIX;
61 static const std::string MESSAGE_DISCAREDED_TOPIC_PREFIX;
62 static const std::string FULL_TOPIC_PREFIX;
63 static const std::string MESSAGE_DELIVERED_TOPIC_PREFIX;
64 static const std::string MESSAGE_CONSUMED_TOPIC_PREFIX;
65 static const std::string MESSAGE_DLQ_TOPIC_PREFIX;
66 static const std::string MASTER_BROKER_TOPIC_PREFIX;
67 static const std::string NETWORK_BRIDGE_TOPIC_PREFIX;
68 static const std::string AGENT_TOPIC;
69 static const std::string ADIVSORY_MESSAGE_TYPE;
70 static const std::string MSG_PROPERTY_ORIGIN_BROKER_ID;
71 static const std::string MSG_PROPERTY_ORIGIN_BROKER_NAME;
72 static const std::string MSG_PROPERTY_ORIGIN_BROKER_URL;
73 static const std::string MSG_PROPERTY_USAGE_NAME;
74 static const std::string MSG_PROPERTY_CONSUMER_ID;
75 static const std::string MSG_PROPERTY_PRODUCER_ID;
76 static const std::string MSG_PROPERTY_MESSAGE_ID;
77 static const std::string MSG_PROPERTY_CONSUMER_COUNT;
78 static const std::string MSG_PROPERTY_DISCARDED_COUNT;
79
80 public:
81
83
84 public:
85
93
101
108 static std::vector<commands::ActiveMQDestination*> getAllDestinationAdvisoryTopics(const cms::Destination* destination);
109
116 static std::vector<commands::ActiveMQDestination*> getAllDestinationAdvisoryTopics(const commands::ActiveMQDestination* destination);
117
124
131
138
145
152
159
166
173
180
188
196
204
212
220
228
236
244
252
260
268
276
284
292
300
308
316
324
332
340
348
356
364
372
379
386
394
402
410
418
419 public:
420
424 static bool isDestinationAdvisoryTopic(const cms::Destination* destination);
425
430
434 static bool isTempDestinationAdvisoryTopic(const cms::Destination* destination);
435
440
444 static bool isAdvisoryTopic(const cms::Destination* destination);
445
449 static bool isAdvisoryTopic(const commands::ActiveMQDestination* destination);
450
454 static bool isConnectionAdvisoryTopic(const cms::Destination* destination);
455
460
464 static bool isProducerAdvisoryTopic(const cms::Destination* destination);
465
470
474 static bool isConsumerAdvisoryTopic(const cms::Destination* destination);
475
480
484 static bool isSlowConsumerAdvisoryTopic(const cms::Destination* destination);
485
490
494 static bool isFastProducerAdvisoryTopic(const cms::Destination* destination);
495
500
504 static bool isMessageConsumedAdvisoryTopic(const cms::Destination* destination);
505
510
514 static bool isMasterBrokerAdvisoryTopic(const cms::Destination* destination);
515
520
524 static bool isMessageDeliveredAdvisoryTopic(const cms::Destination* destination);
525
530
534 static bool isMessageDiscardedAdvisoryTopic(const cms::Destination* destination);
535
540
544 static bool isMessageDLQdAdvisoryTopic(const cms::Destination* destination);
545
550
554 static bool isFullAdvisoryTopic(const cms::Destination* destination);
555
559 static bool isFullAdvisoryTopic(const commands::ActiveMQDestination* destination);
560
564 static bool isNetworkBridgeAdvisoryTopic(const cms::Destination* destination);
565
570
571 };
572
573}}
574
575#endif /* _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