svn commit: r588704 - in /activemq/activemq-cpp/trunk/src/examples: consumers/SimpleAsyncConsumer.cpp producers/SimpleProducer.cpp

[ta...@apache.org]

Author: tabish
Date: Fri Oct 26 09:34:15 2007
New Revision: 588704

URL: http://svn.apache.org/viewvc?rev=588704&view=rev
Log:
Adding more examples for the CPP client, this is a simple async consumer example and a simple producer.

Modified:
    activemq/activemq-cpp/trunk/src/examples/consumers/SimpleAsyncConsumer.cpp
    activemq/activemq-cpp/trunk/src/examples/producers/SimpleProducer.cpp

Modified: activemq/activemq-cpp/trunk/src/examples/consumers/SimpleAsyncConsumer.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/examples/consumers/SimpleAsyncConsumer.cpp?rev=588704&r1=588703&r2=588704&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/examples/consumers/SimpleAsyncConsumer.cpp (original)
+++ activemq/activemq-cpp/trunk/src/examples/consumers/SimpleAsyncConsumer.cpp Fri Oct 26 09:34:15 2007
@@ -209,7 +209,7 @@
     // customize where the consumer listens, to have the consumer
     // use a topic or queue set the 'useTopics' flag.
     //============================================================
-    std::string destURI = "TEST.FOO";
+    std::string destURI = "TEST.FOO"; //?consumer.prefetchSize=1";
 
     //============================================================
     // set to true to use topics instead of queues

Modified: activemq/activemq-cpp/trunk/src/examples/producers/SimpleProducer.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/examples/producers/SimpleProducer.cpp?rev=588704&r1=588703&r2=588704&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/examples/producers/SimpleProducer.cpp (original)
+++ activemq/activemq-cpp/trunk/src/examples/producers/SimpleProducer.cpp Fri Oct 26 09:34:15 2007
@@ -90,9 +90,9 @@
 
             // Create the destination (Topic or Queue)
             if( useTopic ) {
-                destination = session->createTopic( "TEST.FOO" );
+                destination = session->createTopic( destURI );
             } else {
-                destination = session->createQueue( "TEST.FOO" );
+                destination = session->createQueue( destURI );
             }
 
             // Create a MessageProducer from the Session to the Topic or Queue
@@ -189,7 +189,7 @@
     //============================================================
     // Total number of messages for this producer to send.
     //============================================================
-    unsigned int numMessages = 2000;
+    unsigned int numMessages = 32730;
 
     //============================================================
     // This is the Destination Name and URI options.  Use this to