You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2007/03/14 19:03:27 UTC
svn commit: r518246 - in /incubator/qpid/branches/qpid.0-9: ./
cpp/lib/client/ClientChannel.cpp
Author: aconway
Date: Wed Mar 14 11:03:26 2007
New Revision: 518246
URL: http://svn.apache.org/viewvc?view=rev&rev=518246
Log:
Merged revisions 507582 via svnmerge from
https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid
........
r507582 | gsim | 2007-02-14 10:38:57 -0500 (Wed, 14 Feb 2007) | 3 lines
Add durability property to queues and pass this to broker on declare.
........
Modified:
incubator/qpid/branches/qpid.0-9/ (props changed)
incubator/qpid/branches/qpid.0-9/cpp/lib/client/ClientChannel.cpp
Propchange: incubator/qpid/branches/qpid.0-9/
------------------------------------------------------------------------------
--- svnmerge-integrated (original)
+++ svnmerge-integrated Wed Mar 14 11:03:26 2007
@@ -1 +1 @@
-/incubator/qpid/trunk/qpid:1-492620,492636,492641,493126-493151,494540,494553,494587,495629,495661,496317,496665,496678,497341,497439,498591,499049,499374,499803,499845,499847,499864,506406,506967,506972,507455,507457-507458,507472
+/incubator/qpid/trunk/qpid:1-492620,492636,492641,493126-493151,494540,494553,494587,495629,495661,496317,496665,496678,497341,497439,498591,499049,499374,499803,499845,499847,499864,506406,506967,506972,507455,507457-507458,507472,507582
Modified: incubator/qpid/branches/qpid.0-9/cpp/lib/client/ClientChannel.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/cpp/lib/client/ClientChannel.cpp?view=diff&rev=518246&r1=518245&r2=518246
==============================================================================
--- incubator/qpid/branches/qpid.0-9/cpp/lib/client/ClientChannel.cpp (original)
+++ incubator/qpid/branches/qpid.0-9/cpp/lib/client/ClientChannel.cpp Wed Mar 14 11:03:26 2007
@@ -149,7 +149,7 @@
new QueueDeclareBody(
version, 0, name, false/*passive*/, queue.isDurable(),
queue.isExclusive(), queue.isAutoDelete(), !synch, args));
- if (synch) {
+ if(synch){
if(queue.getName().length() == 0){
QueueDeclareOkBody::shared_ptr response =
shared_polymorphic_downcast<QueueDeclareOkBody>(