diff options
Diffstat (limited to 'cpp/src/qpid/cluster/PollerDispatch.cpp')
| -rw-r--r-- | cpp/src/qpid/cluster/PollerDispatch.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/cpp/src/qpid/cluster/PollerDispatch.cpp b/cpp/src/qpid/cluster/PollerDispatch.cpp index a839ef863b..b8d94b95a5 100644 --- a/cpp/src/qpid/cluster/PollerDispatch.cpp +++ b/cpp/src/qpid/cluster/PollerDispatch.cpp @@ -60,8 +60,10 @@ void PollerDispatch::dispatch(sys::DispatchHandle& h) { // Entry point: called if disconnected from CPG. void PollerDispatch::disconnect(sys::DispatchHandle& ) { - QPID_LOG(critical, "Disconnected from cluster"); - onError(); + if (!poller->hasShutdown()) { + QPID_LOG(critical, "Disconnected from cluster"); + onError(); + } } }} // namespace qpid::cluster |