diff options
Diffstat (limited to 'cpp/src/qpid/broker/SessionState.h')
| -rw-r--r-- | cpp/src/qpid/broker/SessionState.h | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/SessionState.h b/cpp/src/qpid/broker/SessionState.h index f5f1bde2a2..29ca2665ea 100644 --- a/cpp/src/qpid/broker/SessionState.h +++ b/cpp/src/qpid/broker/SessionState.h @@ -55,6 +55,8 @@ class ConnectionState; class Message; class SessionHandler; class SessionManager; +class RateFlowcontrol; +class TimerTask; /** * Broker-side session state includes session's handler chains, which @@ -132,7 +134,11 @@ class SessionState : public qpid::SessionState, qmf::org::apache::qpid::broker::Session* mgmtObject; qpid::framing::SequenceSet accepted; - friend class SessionManager; + // State used for producer flow control (rate limited) + RateFlowcontrol* rateFlowcontrol; + boost::intrusive_ptr<TimerTask> flowControlTimer; + + friend class SessionManager; }; |
