summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/broker/DeliveryRecord.h
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2011-07-28 18:28:56 +0000
committerAlan Conway <aconway@apache.org>2011-07-28 18:28:56 +0000
commit95ad2adfc443b227eba224279188c36906c1db66 (patch)
tree14c91400e2284b2c4f782d203a60d44dbee31f9e /qpid/cpp/src/qpid/broker/DeliveryRecord.h
parent8db25489a2971803b21d73814521b40731111bd5 (diff)
downloadqpid-python-qpid-3163.tar.gz
Merge branch 'visibility-hidden' into qpid-3163qpid-3163
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3163@1151956 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qpid/broker/DeliveryRecord.h')
-rw-r--r--qpid/cpp/src/qpid/broker/DeliveryRecord.h16
1 files changed, 8 insertions, 8 deletions
diff --git a/qpid/cpp/src/qpid/broker/DeliveryRecord.h b/qpid/cpp/src/qpid/broker/DeliveryRecord.h
index d388ba94be..cb986df92c 100644
--- a/qpid/cpp/src/qpid/broker/DeliveryRecord.h
+++ b/qpid/cpp/src/qpid/broker/DeliveryRecord.h
@@ -10,9 +10,9 @@
* 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
@@ -42,7 +42,7 @@ struct AckRange;
/**
* Record of a delivery for which an ack is outstanding.
*/
-class DeliveryRecord
+class QPID_BROKER_CLASS_EXTERN DeliveryRecord
{
QueuedMessage msg;
mutable boost::shared_ptr<Queue> queue;
@@ -66,16 +66,16 @@ class DeliveryRecord
public:
QPID_BROKER_EXTERN DeliveryRecord(const QueuedMessage& msg,
- const boost::shared_ptr<Queue>& queue,
+ const boost::shared_ptr<Queue>& queue,
const std::string& tag,
bool acquired,
bool accepted,
bool windowing,
uint32_t credit=0 // Only used if msg is empty.
);
-
+
bool coveredBy(const framing::SequenceSet* const range) const { return range->contains(id); }
-
+
void dequeue(TransactionContext* ctxt = 0) const;
void requeue() const;
void release(bool setRedelivered);
@@ -95,7 +95,7 @@ class DeliveryRecord
bool isAccepted() const { return !acceptExpected; }
bool isEnded() const { return ended; }
bool isWindowing() const { return windowing; }
-
+
uint32_t getCredit() const;
const std::string& getTag() const { return tag; }
@@ -132,7 +132,7 @@ typedef DeliveryRecord::DeliveryRecords DeliveryRecords;
struct AckRange
{
DeliveryRecords::iterator start;
- DeliveryRecords::iterator end;
+ DeliveryRecords::iterator end;
AckRange(DeliveryRecords::iterator _start, DeliveryRecords::iterator _end) : start(_start), end(_end) {}
};