activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r739314 - /activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.cpp
Date Fri, 30 Jan 2009 15:56:45 GMT
Author: tabish
Date: Fri Jan 30 15:56:44 2009
New Revision: 739314

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

Additional refinements in the Core classes. (update test to pass)

Modified:
    activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.cpp

Modified: activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.cpp?rev=739314&r1=739313&r2=739314&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.cpp (original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/core/ActiveMQSessionTest.cpp Fri Jan 30
15:56:44 2009
@@ -75,8 +75,7 @@
     consumer1->setMessageListener( &msgListener1 );
     consumer2->setMessageListener( &msgListener2 );
 
-    injectTextMessage( "This is a Test 1" , *topic1,
-                       *( consumer1->getConsumerInfo()->getConsumerId() ) );
+    injectTextMessage( "This is a Test 1" , *topic1, consumer1->getConsumerId() );
 
     synchronized( &msgListener1.mutex )
     {
@@ -88,8 +87,7 @@
 
     CPPUNIT_ASSERT( msgListener1.messages.size() == 1 );
 
-    injectTextMessage( "This is a Test 2" , *topic2,
-                       *( consumer2->getConsumerInfo()->getConsumerId() ) );
+    injectTextMessage( "This is a Test 2" , *topic2, consumer2->getConsumerId() );
 
     synchronized( &msgListener2.mutex )
     {
@@ -165,8 +163,7 @@
     consumer1->setMessageListener( &msgListener1 );
     consumer2->setMessageListener( &msgListener2 );
 
-    injectTextMessage( "This is a Test 1" , *topic1,
-                       *( consumer1->getConsumerInfo()->getConsumerId() ) );
+    injectTextMessage( "This is a Test 1" , *topic1, consumer1->getConsumerId() );
 
     synchronized( &msgListener1.mutex )
     {
@@ -180,8 +177,7 @@
 
     msgListener1.messages[0]->acknowledge();
 
-    injectTextMessage( "This is a Test 2" , *topic2,
-                       *( consumer2->getConsumerInfo()->getConsumerId() ) );
+    injectTextMessage( "This is a Test 2" , *topic2, consumer2->getConsumerId() );
 
     synchronized( &msgListener2.mutex )
     {
@@ -259,8 +255,7 @@
     consumer1->setMessageListener( &msgListener1 );
     consumer2->setMessageListener( &msgListener2 );
 
-    injectTextMessage( "This is a Test 1" , *topic1,
-                       *( consumer1->getConsumerInfo()->getConsumerId() ) );
+    injectTextMessage( "This is a Test 1" , *topic1, consumer1->getConsumerId() );
 
     synchronized( &msgListener1.mutex )
     {
@@ -274,8 +269,7 @@
 
     session->commit();
 
-    injectTextMessage( "This is a Test 2" , *topic2,
-                       *( consumer2->getConsumerInfo()->getConsumerId() ) );
+    injectTextMessage( "This is a Test 2" , *topic2, consumer2->getConsumerId() );
 
     synchronized( &msgListener2.mutex )
     {
@@ -316,8 +310,7 @@
 
         stream << "This is test message #" << i << std::ends;
 
-        injectTextMessage( stream.str() , *topic1,
-                           *( consumer1->getConsumerInfo()->getConsumerId() ) );
+        injectTextMessage( stream.str() , *topic1, consumer1->getConsumerId() );
     }
 
     for( unsigned int i = 0; i < msgCount; ++i )
@@ -326,8 +319,7 @@
 
         stream << "This is test message #" << i << std::ends;
 
-        injectTextMessage( stream.str() , *topic2,
-                           *( consumer2->getConsumerInfo()->getConsumerId() ) );
+        injectTextMessage( stream.str() , *topic2, consumer2->getConsumerId() );
     }
 
     synchronized( &msgListener1.mutex )
@@ -440,7 +432,7 @@
 
     injectTextMessage( "This is a Test 1" ,
                        *topic1,
-                       *( consumer1->getConsumerInfo()->getConsumerId() ),
+                       consumer1->getConsumerId(),
                        decaf::util::Date::getCurrentTimeMilliseconds(),
                        50 );
 
@@ -456,7 +448,7 @@
 
     injectTextMessage( "This is a Test 2" ,
                        *topic2,
-                       *( consumer2->getConsumerInfo()->getConsumerId() ),
+                       consumer2->getConsumerId(),
                        decaf::util::Date::getCurrentTimeMilliseconds() - 100,
                        1 );
 



Mime
View raw message