activemq-cpp-3.9.5
PrefetchPolicy.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_CORE_PREFETCHPOLICY_H_
19#define _ACTIVEMQ_CORE_PREFETCHPOLICY_H_
20
22
24
25namespace activemq {
26namespace core {
27
34 class AMQCPP_API PrefetchPolicy {
35 private:
36
37 PrefetchPolicy(const PrefetchPolicy&);
38 PrefetchPolicy& operator=(const PrefetchPolicy&);
39
40 protected:
41
43
44 public:
45
46 virtual ~PrefetchPolicy();
47
54 virtual void setDurableTopicPrefetch(int value) = 0;
55
61 virtual int getDurableTopicPrefetch() const = 0;
62
69 virtual void setQueuePrefetch(int value) = 0;
70
76 virtual int getQueuePrefetch() const = 0;
77
84 virtual void setQueueBrowserPrefetch(int value) = 0;
85
91 virtual int getQueueBrowserPrefetch() const = 0;
92
99 virtual void setTopicPrefetch(int value) = 0;
100
106 virtual int getTopicPrefetch() const = 0;
107
114 virtual void setAll(int value);
115
123 virtual int getMaxPrefetchLimit(int value) const = 0;
124
130 virtual PrefetchPolicy* clone() const = 0;
131
148 virtual void configure(const decaf::util::Properties& properties);
149
150 };
151
152}}
153
154#endif /* _ACTIVEMQ_CORE_PREFETCHPOLICY_H_ */
#define AMQCPP_API
Definition Config.h:30
virtual void setQueuePrefetch(int value)=0
Sets the amount of prefetched messages for a Queue.
virtual int getTopicPrefetch() const =0
Gets the amount of messages to prefetch for a Topic.
virtual void setDurableTopicPrefetch(int value)=0
Sets the amount of prefetched messages for a Durable Topic.
virtual int getQueueBrowserPrefetch() const =0
Gets the amount of messages to prefetch for a Queue Browser.
virtual void setTopicPrefetch(int value)=0
Sets the amount of prefetched messages for a Topic.
virtual void configure(const decaf::util::Properties &properties)
Checks the supplied properties object for properties matching the configurable settings of this class...
virtual PrefetchPolicy * clone() const =0
Clone the Policy and return a new pointer to that clone.
virtual void setQueueBrowserPrefetch(int value)=0
Sets the amount of prefetched messages for a Queue Browser.
virtual void setAll(int value)
Sets the prefetch value on all available prefetch configuration options.
virtual int getDurableTopicPrefetch() const =0
Gets the amount of messages to prefetch for a Durable Topic.
virtual int getMaxPrefetchLimit(int value) const =0
Given a requested value for a new prefetch limit, compare it against some max prefetch value and retu...
virtual int getQueuePrefetch() const =0
Gets the amount of messages to prefetch for a Queue.
Java-like properties class for mapping string names to string values.
Definition Properties.h:53
Definition ActiveMQTempDestination.h:29
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24