activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r920323 - /activemq/activemq-cpp/branches/activemq-cpp-3.1.x/activemq-cpp/src/examples/advisories/AdvisoryProducerMain.cpp
Date Mon, 08 Mar 2010 13:55:12 GMT
Author: tabish
Date: Mon Mar  8 13:55:12 2010
New Revision: 920323

URL: http://svn.apache.org/viewvc?rev=920323&view=rev
Log:
fix for: http://issues.apache.org/activemq/browse/AMQCPP-273

Modified:
    activemq/activemq-cpp/branches/activemq-cpp-3.1.x/activemq-cpp/src/examples/advisories/AdvisoryProducerMain.cpp

Modified: activemq/activemq-cpp/branches/activemq-cpp-3.1.x/activemq-cpp/src/examples/advisories/AdvisoryProducerMain.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/branches/activemq-cpp-3.1.x/activemq-cpp/src/examples/advisories/AdvisoryProducerMain.cpp?rev=920323&r1=920322&r2=920323&view=diff
==============================================================================
--- activemq/activemq-cpp/branches/activemq-cpp-3.1.x/activemq-cpp/src/examples/advisories/AdvisoryProducerMain.cpp
(original)
+++ activemq/activemq-cpp/branches/activemq-cpp-3.1.x/activemq-cpp/src/examples/advisories/AdvisoryProducerMain.cpp
Mon Mar  8 13:55:12 2010
@@ -52,39 +52,41 @@
     //
     std::string brokerURI = "failover:(tcp://127.0.0.1:61616)";
 
-    // Create the Connection
-    auto_ptr<cms::ConnectionFactory> connectionFactory(
-        cms::ConnectionFactory::createCMSConnectionFactory( brokerURI ) );
-
-    auto_ptr<cms::Connection> connection;
-
-    // Create a Connection
-    try{
-        connection.reset( connectionFactory->createConnection() );
-    } catch( CMSException& e ) {
-        e.printStackTrace();
-        return 1;
+    {
+        // Create the Connection
+        auto_ptr<cms::ConnectionFactory> connectionFactory(
+            cms::ConnectionFactory::createCMSConnectionFactory( brokerURI ) );
+
+        auto_ptr<cms::Connection> connection;
+
+        // Create a Connection
+        try{
+            connection.reset( connectionFactory->createConnection() );
+        } catch( CMSException& e ) {
+            e.printStackTrace();
+            return 1;
+        }
+
+        // Create the Session
+        std::auto_ptr<cms::Session> session( connection->createSession() );
+
+        // Create the producer and run it.
+        AdvisoryProducer advisoryProducer( session.get() );
+        Thread runner( &advisoryProducer );
+        runner.start();
+
+        // Start the Connection now.
+        connection->start();
+
+        // Wait until we are told to quit.
+        std::cout << "Press 'q' to quit" << std::endl;
+        while( std::cin.get() != 'q') {}
+
+        // Shutdown now
+        advisoryProducer.stop();
+        connection->stop();
     }
 
-    // Create the Session
-    std::auto_ptr<cms::Session> session( connection->createSession() );
-
-    // Create the producer and run it.
-    AdvisoryProducer advisoryProducer( session.get() );
-    Thread runner( &advisoryProducer );
-    runner.start();
-
-    // Start the Connection now.
-    connection->start();
-
-    // Wait until we are told to quit.
-    std::cout << "Press 'q' to quit" << std::endl;
-    while( std::cin.get() != 'q') {}
-
-    // Shutdown now
-    advisoryProducer.stop();
-    connection->stop();
-
     std::cout << "-----------------------------------------------------\n";
     std::cout << "Finished with the example." << std::endl;
     std::cout << "=====================================================\n";



Mime
View raw message