activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r482770 - /incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/connector/stomp/StompSessionManagerTest.h
Date Tue, 05 Dec 2006 20:39:39 GMT
Author: tabish
Date: Tue Dec  5 12:39:38 2006
New Revision: 482770

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

Adding more unit tests for changes from this issue.

Modified:
    incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/connector/stomp/StompSessionManagerTest.h

Modified: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/connector/stomp/StompSessionManagerTest.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/connector/stomp/StompSessionManagerTest.h?view=diff&rev=482770&r1=482769&r2=482770
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/connector/stomp/StompSessionManagerTest.h
(original)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/connector/stomp/StompSessionManagerTest.h
Tue Dec  5 12:39:38 2006
@@ -374,6 +374,34 @@
             cmdListener.cmd = NULL;
             cmdListener.subscribe = NULL;
 
+            cmdListener.expected.clear();
+            cmdListener.expected.push_back( retroactive );         
+            cmdListener.expected.push_back( prefetchSize );         
+            cmdListener.expected.push_back( maxPendingMsgLimit );         
+            cmdListener.expected.push_back( noLocal );         
+            cmdListener.expected.push_back( dispatchAsync );         
+            cmdListener.expected.push_back( selector );         
+            cmdListener.expected.push_back( exclusive );         
+            cmdListener.expected.push_back( priority );         
+            StompTopic dest4( 
+                std::string( "dummy.topic.1?" ) + 
+                "consumer.retroactive=" + retroactive.second + "&" +
+                "consumer.prefetchSize=" + prefetchSize.second + "&" +
+                "consumer.maximumPendingMessageLimit=" + maxPendingMsgLimit.second + "&"
+
+                "consumer.dispatchAsync=" + dispatchAsync.second + "&" +
+                "consumer.selector=" + selector.second + "&" +
+                "consumer.exclusive=" + exclusive.second + "&" +
+                "consumer.priority=" + priority.second );
+            consumer = manager.createConsumer( &dest4, session, "", true );         
          
+            CPPUNIT_ASSERT( consumer != NULL );
+            CPPUNIT_ASSERT( cmdListener.subscribe != NULL );            
+
+            manager.removeConsumer( consumer );
+            CPPUNIT_ASSERT( cmdListener.cmd != NULL );
+            delete consumer;
+            cmdListener.cmd = NULL;
+            cmdListener.subscribe = NULL;
+
             // Done
             delete session;
 



Mime
View raw message