diff options
Diffstat (limited to 'cpp/src/qpid/cluster/OutputInterceptor.cpp')
| -rw-r--r-- | cpp/src/qpid/cluster/OutputInterceptor.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/cpp/src/qpid/cluster/OutputInterceptor.cpp b/cpp/src/qpid/cluster/OutputInterceptor.cpp index effd2c5bff..68afb9bda0 100644 --- a/cpp/src/qpid/cluster/OutputInterceptor.cpp +++ b/cpp/src/qpid/cluster/OutputInterceptor.cpp @@ -37,6 +37,7 @@ OutputInterceptor::OutputInterceptor(cluster::Connection& p, sys::ConnectionOutp {} void OutputInterceptor::send(framing::AMQFrame& f) { + parent.getCluster().checkQuorum(); Locker l(lock); next->send(f); if (!parent.isCatchUp()) |