diff options
| author | Andrew Stitcher <astitcher@apache.org> | 2009-02-02 22:28:17 +0000 |
|---|---|---|
| committer | Andrew Stitcher <astitcher@apache.org> | 2009-02-02 22:28:17 +0000 |
| commit | f6f519835a049e53f13af818e26decba1fc82f3d (patch) | |
| tree | 10c71151ad6d0871da35923d12c97fa2e0826c75 /cpp/src/qpid/client/ConnectionHandler.cpp | |
| parent | e5d4d995196e8a48cf7bc2180738b9bf5c3cb14f (diff) | |
| download | qpid-python-f6f519835a049e53f13af818e26decba1fc82f3d.tar.gz | |
Send client property indicating that client supports
producer throttling in the Connection.OpenOK message.
Broker only tries to apply flow control to client if it
has received the property in the Connection.OpenOK message.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@740135 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/ConnectionHandler.cpp')
| -rw-r--r-- | cpp/src/qpid/client/ConnectionHandler.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/ConnectionHandler.cpp b/cpp/src/qpid/client/ConnectionHandler.cpp index d6d024cf3f..377b84c019 100644 --- a/cpp/src/qpid/client/ConnectionHandler.cpp +++ b/cpp/src/qpid/client/ConnectionHandler.cpp @@ -51,6 +51,8 @@ const std::string INVALID_STATE_TUNE("tune received in invalid state"); const std::string INVALID_STATE_OPEN_OK("open-ok received in invalid state"); const std::string INVALID_STATE_CLOSE_OK("close-ok received in invalid state"); +const std::string SESSION_FLOW_CONTROL("qpid.session_flow"); +const int SESSION_FLOW_CONTROL_VER = 1; } CloseCode ConnectionHandler::convert(uint16_t replyCode) @@ -76,6 +78,8 @@ ConnectionHandler::ConnectionHandler(const ConnectionSettings& s, ProtocolVersio FINISHED.insert(FAILED); FINISHED.insert(CLOSED); + + properties.setInt(SESSION_FLOW_CONTROL, SESSION_FLOW_CONTROL_VER); } void ConnectionHandler::incoming(AMQFrame& frame) |