From 14fffae30f6157a79c79ff4908d2eb68baf2143f Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Mon, 10 Sep 2007 18:37:36 +0000 Subject: Support for keyword args in session interface git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574323 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/tests/ClientSessionTest.cpp | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) (limited to 'qpid/cpp/src/tests/ClientSessionTest.cpp') diff --git a/qpid/cpp/src/tests/ClientSessionTest.cpp b/qpid/cpp/src/tests/ClientSessionTest.cpp index a3d50d0ae9..9f68716104 100644 --- a/qpid/cpp/src/tests/ClientSessionTest.cpp +++ b/qpid/cpp/src/tests/ClientSessionTest.cpp @@ -50,7 +50,7 @@ class ClientSessionTest : public CppUnit::TestCase { std::string name("my-queue"); std::string alternate("amq.fanout"); - session.queueDeclare(0, name, alternate, false, false, true, true, FieldTable()); + session.queueDeclare((queue=name, alternateExchange=alternate, exclusive=true, autoDelete=true)); TypedResult result = session.queueQuery(name); CPPUNIT_ASSERT_EQUAL(false, result.get().getDurable()); CPPUNIT_ASSERT_EQUAL(true, result.get().getExclusive()); @@ -59,16 +59,16 @@ class ClientSessionTest : public CppUnit::TestCase void testTransfer() { - std::string queue("my-queue"); + std::string queueName("my-queue"); std::string dest("my-dest"); std::string data("my message"); - session.queueDeclare(0, queue, "", false, false, true, true, FieldTable()); + session.queueDeclare_(queue=queueName, exclusive=true, autoDelete=true); //subcribe to the queue with confirm_mode = 1: - session.messageSubscribe(0, queue, dest, false, 1, 0, false, FieldTable()); + session.messageSubscribe_(queue=queueName, destination=dest, acquireMode=1); //publish a message: - TransferContent content(data); - content.getDeliveryProperties().setRoutingKey("my-queue"); - session.messageTransfer(0, "", 0, 0, content); + TransferContent _content(data); + _content.getDeliveryProperties().setRoutingKey("my-queue"); + session.messageTransfer_(content=_content); //get & test the message: FrameSet::shared_ptr msg = session.get(); CPPUNIT_ASSERT(msg->isA()); -- cgit v1.2.1