summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/ha/IdSetter.h
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/src/qpid/ha/IdSetter.h')
-rw-r--r--qpid/cpp/src/qpid/ha/IdSetter.h7
1 files changed, 2 insertions, 5 deletions
diff --git a/qpid/cpp/src/qpid/ha/IdSetter.h b/qpid/cpp/src/qpid/ha/IdSetter.h
index a56dbc810a..dc9fa90af9 100644
--- a/qpid/cpp/src/qpid/ha/IdSetter.h
+++ b/qpid/cpp/src/qpid/ha/IdSetter.h
@@ -44,13 +44,10 @@ class IdSetter : public broker::MessageInterceptor
{
public:
IdSetter(const std::string& q, ReplicationId firstId) : nextId(firstId), name(q) {
- QPID_LOG(trace, "Initial replication ID for " << name << " is " << nextId.get());
+ QPID_LOG(trace, "Initial replication ID for " << name << " =" << nextId.get());
}
- void record(broker::Message& m) {
- m.setReplicationId(nextId++);
- QPID_LOG(trace, "Recorded replication ID " << m.getReplicationId() << " on " << name);
- }
+ void record(broker::Message& m) { m.setReplicationId(nextId++); }
private:
sys::AtomicValue<uint32_t> nextId;