[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-commits
Subject:    svn commit: r739314 -
From:       tabish () apache ! org
Date:       2009-01-30 15:56:45
Message-ID: 20090130155645.3B9AF23888A0 () eris ! apache ! org
[Download RAW message or body]

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 );
 


[prev in list] [next in list] [prev in thread] [next in thread]