1 /*------------------------------------------------------------------------------
2 Name: UpdateQos.cpp
3 Project: xmlBlaster.org
4 Copyright: xmlBlaster.org, see xmlBlaster-LICENSE file
5 ------------------------------------------------------------------------------*/
6
7 # include <client/qos/UpdateQos.h>
8
9 using namespace org::xmlBlaster::util;
10 using namespace org::xmlBlaster::util::qos;
11 using namespace org::xmlBlaster::util::cluster;
12
13 using namespace std;
14
15 namespace org { namespace xmlBlaster { namespace client { namespace qos {
16
17 UpdateQos::UpdateQos(Global& global, const MsgQosData data)
18 : GetReturnQos(global, data)
19 {
20 ME = "UpdateQos";
21 }
22
23 UpdateQos::UpdateQos(const UpdateQos& data)
24 : GetReturnQos(data)
25 {
26 ME = data.ME;
27 }
28
29 UpdateQos& UpdateQos::operator=(const UpdateQos& data)
30 {
31 GetReturnQos::operator=(static_cast<GetReturnQos>(data));
32 ME = data.ME;
33 return *this;
34 }
35
36 /**
37 * Test if Publish/Subscribe style is used.
38 *
39 * @return true if Publish/Subscribe style is used
40 * false if addressing of the destination is used
41 */
42 bool UpdateQos::isSubscribable() const
43 {
44 return data_.isSubscribable();
45 }
46
47 /**
48 * Test if Point to Point addressing style is used.
49 *
50 * @return true if addressing of the destination is used
51 * false if Publish/Subscribe style is used
52 */
53 bool UpdateQos::isPtp()
54 {
55 return data_.isPtp();
56 }
57
58 /**
59 * If Pub/Sub style update: contains the subscribe ID which caused this update
60 * @return subscribeId or null if PtP message
61 */
62 string UpdateQos::getSubscriptionId() const
63 {
64 return data_.getSubscriptionId();
65 }
66
67 /**
68 * Returns > 0 if the message probably is redelivered.
69 * @return == 0 The message is guaranteed to be delivered only once.
70 */
71 int UpdateQos::getRedeliver() const
72 {
73 return data_.getRedeliver();
74 }
75
76 /**
77 * @return The number of queued messages
78 */
79 long UpdateQos::getQueueSize() const
80 {
81 return data_.getQueueSize();
82 }
83
84 /**
85 * @return The index of the message in the queue
86 */
87 long UpdateQos::getQueueIndex() const
88 {
89 return data_.getQueueIndex();
90 }
91
92 bool UpdateQos::isOk() const
93 {
94 return data_.isOk();
95 }
96
97 bool UpdateQos::isErased() const
98 {
99 return data_.isErased();
100 }
101
102 bool UpdateQos::isTimeout() const
103 {
104 return data_.isTimeout();
105 }
106
107 bool UpdateQos::isForwardError() const
108 {
109 return data_.isForwardError();
110 }
111
112 }}}}
syntax highlighted by Code2HTML, v. 0.9.1