From 9d32e58f281e6ecefcbde45a897395162395e577 Mon Sep 17 00:00:00 2001
From: Alan Conway <aconway@apache.org>
Date: Tue, 30 Oct 2007 22:39:46 +0000
Subject: Client API: fix keyword parameter ambiguities for beta client API.

Classes:
 - client::no_keyword::Session_0_10 -  plain defaulted signatures
 - client::Session_0_10 -  keyword API.

Keyword API changes:
 - keywords in client::arg namespace, user says: s.bind(arg::queue="x"...)
 - user can omit with: using namespace client::arg; s.bind(queue="x"...)
 - No trailing "_" required on session functions.


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@590498 13f79535-47bb-0310-9956-ffa450edef68
---
 cpp/src/qpid/client/Channel.cpp | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

(limited to 'cpp/src/qpid/client/Channel.cpp')

diff --git a/cpp/src/qpid/client/Channel.cpp b/cpp/src/qpid/client/Channel.cpp
index fbb2e0c6f8..9246ead44e 100644
--- a/cpp/src/qpid/client/Channel.cpp
+++ b/cpp/src/qpid/client/Channel.cpp
@@ -44,6 +44,7 @@ using namespace qpid::sys;
 
 namespace qpid{
 namespace client{
+using namespace arg;
 
 const std::string empty;
 
@@ -89,12 +90,12 @@ void Channel::setPrefetch(uint32_t _prefetch){
 
 void Channel::declareExchange(Exchange& _exchange, bool synch){
     ScopedSync s(session, synch);
-    session.exchangeDeclare_(exchange=_exchange.getName(), type=_exchange.getType());
+    session.exchangeDeclare(exchange=_exchange.getName(), type=_exchange.getType());
 }
 
 void Channel::deleteExchange(Exchange& _exchange, bool synch){
     ScopedSync s(session, synch);
-    session.exchangeDelete_(exchange=_exchange.getName(), ifUnused=false);
+    session.exchangeDelete(exchange=_exchange.getName(), ifUnused=false);
 }
 
 void Channel::declareQueue(Queue& _queue, bool synch){
@@ -105,14 +106,14 @@ void Channel::declareQueue(Queue& _queue, bool synch){
     }
 
     ScopedSync s(session, synch);
-    session.queueDeclare_(queue=_queue.getName(), passive=false/*passive*/, durable=_queue.isDurable(),
+    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){
     ScopedSync s(session, synch);
-    session.queueDelete_(queue=_queue.getName(), ifUnused=ifunused, ifEmpty=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){
@@ -180,7 +181,7 @@ bool Channel::get(Message& msg, const Queue& _queue, AckMode ackMode) {
     ScopedDivert handler(tag, session.execution().getDemux());
     Demux::Queue& incoming = handler.getQueue();
 
-    session.messageSubscribe_(destination=tag, queue=_queue.getName(), confirmMode=(ackMode == NO_ACK ? 0 : 1));
+    session.messageSubscribe(destination=tag, queue=_queue.getName(), confirmMode=(ackMode == NO_ACK ? 0 : 1));
     session.messageFlow(tag, 1/*BYTES*/, 0xFFFFFFFF);
     session.messageFlow(tag, 0/*MESSAGES*/, 1);
     Completion status = session.messageFlush(tag);
@@ -203,7 +204,7 @@ void Channel::publish(Message& msg, const Exchange& exchange,
 
     msg.getDeliveryProperties().setRoutingKey(routingKey);
     msg.getDeliveryProperties().setDiscardUnroutable(!mandatory);
-    session.messageTransfer_(destination=exchange.getName(), content=msg);
+    session.messageTransfer(destination=exchange.getName(), content=msg);
 }
 
 void Channel::close()
-- 
cgit v1.2.1