diff options
| author | Gordon Sim <gsim@apache.org> | 2009-02-17 15:44:19 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2009-02-17 15:44:19 +0000 |
| commit | b7d2b4246157131b353f5b62b399946943e896dd (patch) | |
| tree | 36cc4f7ed3d8cc7ce7969471711f599de4117434 /cpp/src/tests/ClientSessionTest.cpp | |
| parent | 65e7c659aaf36d9113956645b95e6c3674cee154 (diff) | |
| download | qpid-python-b7d2b4246157131b353f5b62b399946943e896dd.tar.gz | |
QPID-1667: Test case (fix was submitted in previous rev)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@745125 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/ClientSessionTest.cpp')
| -rw-r--r-- | cpp/src/tests/ClientSessionTest.cpp | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/cpp/src/tests/ClientSessionTest.cpp b/cpp/src/tests/ClientSessionTest.cpp index e156000f18..1658f3d4ec 100644 --- a/cpp/src/tests/ClientSessionTest.cpp +++ b/cpp/src/tests/ClientSessionTest.cpp @@ -548,6 +548,22 @@ QPID_AUTO_TEST_CASE(testLVQVariedSize) { } } +QPID_AUTO_TEST_CASE(testSessionManagerSetFlowControl) { + ClientSessionFixture fix; + std::string name("dummy"); + LocalQueue queue; + SubscriptionSettings settings; + settings.flowControl = FlowControl(); + fix.session.queueDeclare(arg::queue=name, arg::exclusive=true, arg::autoDelete=true); + fix.subs.subscribe(queue, name, settings); + fix.session.messageTransfer(arg::content=Message("my-message", name)); + fix.subs.setFlowControl(name, 1, FlowControl::UNLIMITED, false); + fix.session.messageFlush(name); + Message got; + BOOST_CHECK(queue.get(got, 0)); + BOOST_CHECK_EQUAL("my-message", got.getData()); +} + QPID_AUTO_TEST_SUITE_END() |