diff options
Diffstat (limited to 'cpp/src/qpid/cluster/Multicaster.cpp')
| -rw-r--r-- | cpp/src/qpid/cluster/Multicaster.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cpp/src/qpid/cluster/Multicaster.cpp b/cpp/src/qpid/cluster/Multicaster.cpp index fee13c92c8..4d02d58efe 100644 --- a/cpp/src/qpid/cluster/Multicaster.cpp +++ b/cpp/src/qpid/cluster/Multicaster.cpp @@ -62,7 +62,7 @@ void Multicaster::mcast(const Event& e) { { sys::Mutex::ScopedLock l(lock); LATENCY_TRACK(cpgLatency.start()); - if (e.getType() == DATA && e.isConnection() && holding) { + if (e.isConnection() && holding) { holdingQueue.push_back(e); return; } |