Support for keyword args in session interface

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@574323 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 19 insertions, 21 deletions

diff --git a/cpp/src/qpid/client/ClientChannel.cpp b/cpp/src/qpid/client/ClientChannel.cpp
index 1a0fd25bc3..b77840f433 100644
--- a/cpp/src/qpid/client/ClientChannel.cpp
+++ b/cpp/src/qpid/client/ClientChannel.cpp
@@ -80,7 +80,7 @@ bool Channel::isOpen() const {
 }
 
 void Channel::setQos() {
-    session.basicQos(0, getPrefetch(), false);
+    session.basicQos((prefetchCount=getPrefetch(), global=false));
     if(isTransactional()) {
         //I think this is wrong! should only send TxSelect once...
         session.txSelect();
@@ -92,34 +92,32 @@ void Channel::setPrefetch(uint16_t _prefetch){
     setQos();
 }
 
-void Channel::declareExchange(Exchange& exchange, bool synch){
-    FieldTable args;
+void Channel::declareExchange(Exchange& _exchange, bool synch){
     ScopedSync s(session, synch);
-    session.exchangeDeclare(0, exchange.getName(), exchange.getType(), empty, false, false, false, args);
+    session.exchangeDeclare((exchange=_exchange.getName(), type=_exchange.getType()));
 }
 
-void Channel::deleteExchange(Exchange& exchange, bool synch){
+void Channel::deleteExchange(Exchange& _exchange, bool synch){
     ScopedSync s(session, synch);
-    session.exchangeDelete(0, exchange.getName(), false);
+    session.exchangeDelete((exchange=_exchange.getName(), ifUnused=false));
 }
 
-void Channel::declareQueue(Queue& queue, bool synch){
-    if (queue.getName().empty()) {
+void Channel::declareQueue(Queue& _queue, bool synch){
+    if (_queue.getName().empty()) {
         stringstream uniqueName;
         uniqueName << uniqueId << "-queue-" << ++nameCounter;
-        queue.setName(uniqueName.str());
+        _queue.setName(uniqueName.str());
     }
 
-    FieldTable args;
     ScopedSync s(session, synch);
-    session.queueDeclare(0, queue.getName(), empty, false/*passive*/, queue.isDurable(),
-                          queue.isExclusive(), queue.isAutoDelete(), args);
+    session.queueDeclare((queue=_queue.getName(), passive=false/*passive*/, durable=_queue.isDurable(),
+                              exclusive=_queue.isExclusive(), autoDelete=_queue.isAutoDelete()));
     
 }
 
-void Channel::deleteQueue(Queue& queue, bool ifunused, bool ifempty, bool synch){
+void Channel::deleteQueue(Queue& _queue, bool ifunused, bool ifempty, bool synch){
     ScopedSync s(session, synch);
-    session.queueDelete(0, queue.getName(), ifunused, ifempty);
+    session.queueDelete((queue=_queue.getName(), ifUnused=ifunused, ifEmpty=ifempty));
 }
 
 void Channel::bind(const Exchange& exchange, const Queue& queue, const std::string& key, const FieldTable& args, bool synch){
diff --git a/cpp/src/tests/ClientSessionTest.cpp b/cpp/src/tests/ClientSessionTest.cpp
index a3d50d0ae9..9f68716104 100644
--- a/cpp/src/tests/ClientSessionTest.cpp
+++ b/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>());