summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/tests/ClientSessionTest.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-09-10 18:37:36 +0000
committerGordon Sim <gsim@apache.org>2007-09-10 18:37:36 +0000
commit14fffae30f6157a79c79ff4908d2eb68baf2143f (patch)
treedabd3dbb4246fef83469046181a7b1db55c74d57 /qpid/cpp/src/tests/ClientSessionTest.cpp
parent3236f1ab6e53292792c9629971d649d2310cd7ae (diff)
downloadqpid-python-14fffae30f6157a79c79ff4908d2eb68baf2143f.tar.gz
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
Diffstat (limited to 'qpid/cpp/src/tests/ClientSessionTest.cpp')
-rw-r--r--qpid/cpp/src/tests/ClientSessionTest.cpp14
1 files changed, 7 insertions, 7 deletions
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<QueueQueryResult> 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<MessageTransferBody>());