summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/Connection.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/cluster/Connection.h')
-rw-r--r--cpp/src/qpid/cluster/Connection.h3
1 files changed, 2 insertions, 1 deletions
diff --git a/cpp/src/qpid/cluster/Connection.h b/cpp/src/qpid/cluster/Connection.h
index a6e9aa65f9..4923ef2920 100644
--- a/cpp/src/qpid/cluster/Connection.h
+++ b/cpp/src/qpid/cluster/Connection.h
@@ -146,6 +146,8 @@ class Connection :
// Encoded queue/exchange replication.
void queue(const std::string& encoded);
void exchange(const std::string& encoded);
+
+ void giveReadCredit(int credit) { output.giveReadCredit(credit); }
private:
void init();
@@ -171,7 +173,6 @@ class Connection :
framing::SequenceNumber deliverSeq;
framing::ChannelId currentChannel;
boost::shared_ptr<broker::TxBuffer> txBuffer;
- int readCredit;
bool expectProtocolHeader;
static qpid::sys::AtomicValue<uint64_t> catchUpId;