From a7259adba14345898e78b483b7620340ffa5cfc5 Mon Sep 17 00:00:00 2001 From: "Stephen D. Huston" Date: Thu, 23 Apr 2009 21:06:35 +0000 Subject: Merge in trunk changes from r758432:768028 git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/cmake@768053 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/tests/declare_queues.cpp | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) (limited to 'qpid/cpp/src/tests/declare_queues.cpp') diff --git a/qpid/cpp/src/tests/declare_queues.cpp b/qpid/cpp/src/tests/declare_queues.cpp index 7f61bde12a..d17a72b940 100644 --- a/qpid/cpp/src/tests/declare_queues.cpp +++ b/qpid/cpp/src/tests/declare_queues.cpp @@ -33,14 +33,15 @@ using namespace std; int main(int argc, char ** argv) { ConnectionSettings settings; - if ( argc != 3 ) + if ( argc != 4 ) { - cerr << "Usage: declare_queues host port\n"; + cerr << "Usage: declare_queues host port durability\n"; return 1; } settings.host = argv[1]; settings.port = atoi(argv[2]); + int durability = atoi(argv[3]); FailoverManager connection(settings); try { @@ -48,7 +49,10 @@ int main(int argc, char ** argv) while (!complete) { Session session = connection.connect().newSession(); try { - session.queueDeclare(arg::queue="message_queue"); + if ( durability ) + session.queueDeclare(arg::queue="message_queue", arg::durable=true); + else + session.queueDeclare(arg::queue="message_queue"); complete = true; } catch (const qpid::TransportFailure&) {} } -- cgit v1.2.1