svn commit: r758876 - /activemq/activemq-cpp/trunk/src/examples/main.cpp

[ta...@apache.org]

Author: tabish
Date: Thu Mar 26 21:47:24 2009
New Revision: 758876

URL: http://svn.apache.org/viewvc?rev=758876&view=rev
Log:
cleanup some debug code.

Modified:
    activemq/activemq-cpp/trunk/src/examples/main.cpp

Modified: activemq/activemq-cpp/trunk/src/examples/main.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/examples/main.cpp?rev=758876&r1=758875&r2=758876&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/examples/main.cpp (original)
+++ activemq/activemq-cpp/trunk/src/examples/main.cpp Thu Mar 26 21:47:24 2009
@@ -118,7 +118,6 @@
                 // Tell the producer to send the message
                 printf( "Sent message #%d from thread %s\n", ix+1, threadIdStr.c_str() );
                 producer->send( message );
-				Thread::sleep( 20 );
 
                 delete message;
             }
@@ -357,14 +356,14 @@
     //    tcp://127.0.0.1:61613?wireFormat=stomp     use stomp instead
     //
     std::string brokerURI =
-		"failover://(tcp://127.0.0.1:61616"
+        "tcp://127.0.0.1:61616"
         "?wireFormat=openwire"
 //        "&connection.alwaysSyncSend=true"
 //        "&connection.useAsyncSend=true"
 //        "&transport.commandTracingEnabled=true"
 //        "&transport.tcpTracingEnabled=true"
 //        "&wireFormat.tightEncodingEnabled=true"
-		")";
+        "";
 
     //============================================================
     // set to true to use topics instead of queues
@@ -373,7 +372,7 @@
     //============================================================
     bool useTopics = true;
     bool sessionTransacted = false;
-    int numMessages = 20000;
+    int numMessages = 2000;
 
     long long startTime = Date::getCurrentTimeMilliseconds();