You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2006/12/05 21:39:39 UTC
svn commit: r482770 -
/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/connector/stomp/StompSessionManagerTest.h
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;