svn commit: r518181 - in /activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration: TestSupport.cpp TestSupport.h

[tabish]

Author: tabish
Date: Wed Mar 14 08:30:54 2007
New Revision: 518181

URL: http://svn.apache.org/viewvc?view=rev&rev=518181
Log:
http://issues.apache.org/activemq/browse/AMQCPP-84

Modified:
    
activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/TestSupport.cpp
    
activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/TestSupport.h

Modified: 
activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/TestSupport.cpp
URL: 
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/TestSupport.cpp?view=diff&rev=518181&r1=518180&r2=518181
==============================================================================
--- 
activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/TestSupport.cpp
 (original)
+++ 
activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/TestSupport.cpp
 Wed Mar 14 08:30:54 2007
@@ -119,7 +119,8 @@
 
 unsigned int TestSupport::produceTextMessages(
     cms::MessageProducer& producer,
-    unsigned int count )
+    unsigned int count,
+    cms::Destination* replyTo )
 {
     try
     {
@@ -129,6 +130,7 @@
 
         cms::TextMessage* textMsg =
             session->createTextMessage();
+        textMsg->setCMSReplyTo( replyTo );
 
         unsigned int realCount = 0;
 
@@ -151,7 +153,8 @@
 
 unsigned int TestSupport::produceBytesMessages(
     cms::MessageProducer& producer,
-    unsigned int count )
+    unsigned int count,
+    cms::Destination* replyTo )
 {
     try
     {
@@ -169,6 +172,7 @@
         cms::BytesMessage* bytesMsg =
             session->createBytesMessage();
         bytesMsg->setBodyBytes( buf, 10 );
+        bytesMsg->setCMSReplyTo( replyTo );
 
         unsigned int realCount = 0;
         for( unsigned int ix=0; ix<count; ++ix ){

Modified: 
activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/TestSupport.h
URL: 
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/TestSupport.h?view=diff&rev=518181&r1=518180&r2=518181
==============================================================================
--- 
activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/TestSupport.h
 (original)
+++ 
activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/TestSupport.h
 Wed Mar 14 08:30:54 2007
@@ -33,9 +33,9 @@
     {
     public:
 
-       TestSupport( const std::string& brokerUrl,
+      TestSupport( const std::string& brokerUrl,
                      cms::Session::AcknowledgeMode ackMode = 
cms::Session::AUTO_ACKNOWLEDGE );
-       virtual ~TestSupport();
+      virtual ~TestSupport();
 
         virtual void initialize();
         virtual void close();
@@ -68,10 +68,12 @@
 
         virtual unsigned int produceTextMessages(
             cms::MessageProducer& producer,
-            unsigned int count );
+            unsigned int count,
+            cms::Destination* replyTo = NULL );
         virtual unsigned int produceBytesMessages(
             cms::MessageProducer& producer,
-            unsigned int count );
+            unsigned int count,
+            cms::Destination* replyTo = NULL );
 
         virtual void waitForMessages( unsigned int count );