diff options
| author | Alan Conway <aconway@apache.org> | 2008-02-20 15:26:05 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2008-02-20 15:26:05 +0000 |
| commit | b9c71c852e2e7bbc1635ff62fabf2469e2175399 (patch) | |
| tree | ee3ce9dcd6dc45e76270f6f4d696eb09bfc63895 /cpp/src/tests/ClientSessionTest.cpp | |
| parent | 615beb132f725ebc4a88d58dc5f3b8af8419f932 (diff) | |
| download | qpid-python-b9c71c852e2e7bbc1635ff62fabf2469e2175399.tar.gz | |
Added non-optional enum { SYNC, ASYNC } parameter to newSession.
Updated API doc in client/SessionBase.h
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@629503 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/ClientSessionTest.cpp')
| -rw-r--r-- | cpp/src/tests/ClientSessionTest.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/cpp/src/tests/ClientSessionTest.cpp b/cpp/src/tests/ClientSessionTest.cpp index 87a4f59999..c299837f86 100644 --- a/cpp/src/tests/ClientSessionTest.cpp +++ b/cpp/src/tests/ClientSessionTest.cpp @@ -103,7 +103,7 @@ struct ClientSessionFixture : public ProxySessionFixture }; BOOST_FIXTURE_TEST_CASE(testQueueQuery, ClientSessionFixture) { - session =connection.newSession(); + session =connection.newSession(ASYNC); session.queueDeclare(queue="my-queue", alternateExchange="amq.fanout", exclusive=true, autoDelete=true); TypedResult<QueueQueryResult> result = session.queueQuery(string("my-queue")); BOOST_CHECK_EQUAL(false, result.get().getDurable()); @@ -114,7 +114,7 @@ BOOST_FIXTURE_TEST_CASE(testQueueQuery, ClientSessionFixture) { BOOST_FIXTURE_TEST_CASE(testTransfer, ClientSessionFixture) { - session=connection.newSession(); + session=connection.newSession(ASYNC); declareSubscribe(); session.messageTransfer(content=TransferContent("my-message", "my-queue")); //get & test the message: @@ -127,7 +127,7 @@ BOOST_FIXTURE_TEST_CASE(testTransfer, ClientSessionFixture) BOOST_FIXTURE_TEST_CASE(testDispatcher, ClientSessionFixture) { - session =connection.newSession(); + session =connection.newSession(ASYNC); declareSubscribe(); size_t count = 100; for (size_t i = 0; i < count; ++i) @@ -142,7 +142,7 @@ BOOST_FIXTURE_TEST_CASE(testDispatcher, ClientSessionFixture) /* FIXME aconway 2008-01-28: hangs BOOST_FIXTURE_TEST_CASE(testDispatcherThread, ClientSessionFixture) { - session =connection.newSession(); + session =connection.newSession(ASYNC); declareSubscribe(); size_t count = 10000; DummyListener listener(session, "my-dest", count); @@ -160,7 +160,7 @@ BOOST_FIXTURE_TEST_CASE(testDispatcherThread, ClientSessionFixture) BOOST_FIXTURE_TEST_CASE(_FIXTURE, ClientSessionFixture) { - session =connection.newSession(0); + session =connection.newSession(ASYNC, 0); session.suspend(); // session has 0 timeout. try { connection.resume(session); @@ -170,7 +170,7 @@ BOOST_FIXTURE_TEST_CASE(_FIXTURE, ClientSessionFixture) BOOST_FIXTURE_TEST_CASE(testUseSuspendedError, ClientSessionFixture) { - session =connection.newSession(60); + session =connection.newSession(ASYNC, 60); session.suspend(); try { session.exchangeQuery(name="amq.fanout"); @@ -180,7 +180,7 @@ BOOST_FIXTURE_TEST_CASE(testUseSuspendedError, ClientSessionFixture) BOOST_FIXTURE_TEST_CASE(testSuspendResume, ClientSessionFixture) { - session =connection.newSession(60); + session =connection.newSession(ASYNC, 60); declareSubscribe(); session.suspend(); // Make sure we are still subscribed after resume. |