diff options
Diffstat (limited to 'cpp/src/qpid/ha/QueueGuard.cpp')
| -rw-r--r-- | cpp/src/qpid/ha/QueueGuard.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/ha/QueueGuard.cpp b/cpp/src/qpid/ha/QueueGuard.cpp index 40262a180c..93694af671 100644 --- a/cpp/src/qpid/ha/QueueGuard.cpp +++ b/cpp/src/qpid/ha/QueueGuard.cpp @@ -52,13 +52,13 @@ QueueGuard::QueueGuard(broker::Queue& q, const BrokerInfo& info) : queue(q), subscription(0) { std::ostringstream os; - os << "HA primary guard " << queue.getName() << "@" << info.getLogId() << ": "; + os << "Primary guard " << queue.getName() << "@" << info.getLogId() << ": "; logPrefix = os.str(); observer.reset(new QueueObserver(*this)); // Once we call addObserver we can get calls to enqueued and dequeued queue.addObserver(observer); // Must set after addObserver so we don't miss any enqueues. - firstSafe = queue.getPosition()+1; // Next message will be safe. + firstSafe = queue.getPosition(); // FIXME aconway 2012-06-13: fencepost error } QueueGuard::~QueueGuard() { cancel(); } |