From 091bdea11de78b92ef2ed8232875b105b0c434f3 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Tue, 17 Feb 2009 15:44:19 +0000 Subject: QPID-1667: Test case (fix was submitted in previous rev) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@745125 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/tests/ClientSessionTest.cpp | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/qpid/cpp/src/tests/ClientSessionTest.cpp b/qpid/cpp/src/tests/ClientSessionTest.cpp index e156000f18..1658f3d4ec 100644 --- a/qpid/cpp/src/tests/ClientSessionTest.cpp +++ b/qpid/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() -- cgit v1.2.1