diff options
| author | Alan Conway <aconway@apache.org> | 2008-10-20 13:58:23 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2008-10-20 13:58:23 +0000 |
| commit | 40e17612ff0494ccd440a3a0a3789daabcfb3684 (patch) | |
| tree | 569d53ad5f6280a151eb1f7019c92e9d3e4f9848 /cpp/src/qpid/cluster/DumpClient.cpp | |
| parent | ac0eb22016bf9ae223f147927ba76add8d25dc31 (diff) | |
| download | qpid-python-40e17612ff0494ccd440a3a0a3789daabcfb3684.tar.gz | |
cluster: DumpClient updates consumer notifyEnabled and blocked.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@706293 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/DumpClient.cpp')
| -rw-r--r-- | cpp/src/qpid/cluster/DumpClient.cpp | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/cpp/src/qpid/cluster/DumpClient.cpp b/cpp/src/qpid/cluster/DumpClient.cpp index 58aa14655c..c262115f9f 100644 --- a/cpp/src/qpid/cluster/DumpClient.cpp +++ b/cpp/src/qpid/cluster/DumpClient.cpp @@ -35,6 +35,8 @@ #include "qpid/framing/MessageTransferBody.h" #include "qpid/framing/ClusterConnectionMembershipBody.h" #include "qpid/framing/ClusterConnectionShadowReadyBody.h" +#include "qpid/framing/ClusterConnectionSessionStateBody.h" +#include "qpid/framing/ClusterConnectionConsumerStateBody.h" #include "qpid/framing/enum.h" #include "qpid/framing/ProtocolVersion.h" #include "qpid/log/Statement.h" @@ -227,7 +229,13 @@ void DumpClient::dumpConsumer(broker::SemanticState::ConsumerImpl* ci) { shadowSession.messageSetFlowMode(ci->getName(), ci->isWindowing() ? FLOW_MODE_WINDOW : FLOW_MODE_CREDIT); shadowSession.messageFlow(ci->getName(), CREDIT_UNIT_MESSAGE, ci->getMsgCredit()); shadowSession.messageFlow(ci->getName(), CREDIT_UNIT_BYTE, ci->getByteCredit()); - // FIXME aconway 2008-09-23: need to replicate ConsumerImpl::blocked and notifyEnabled? + ClusterConnectionConsumerStateBody state( + ProtocolVersion(), + ci->getName(), + ci->isBlocked(), + ci->isNotifyEnabld() + ); + client::SessionBase_0_10Access(shadowSession).get()->send(state); QPID_LOG(debug, dumperId << " dumped consumer " << ci->getName() << " on " << shadowSession.getId()); } |