openwire: OpenwireAsyncSenderTest.cpp OpenwireExpirationTest.cpp OpenwireSimpleTest.cpp OpenwireSlowListenerTest.cpp OpenwireTempDestinationTest.cpp

tabish Wed, 29 Oct 2008 16:02:56 -0700

Author: tabish
Date: Wed Oct 29 16:02:33 2008
New Revision: 709039

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


Modified:
    
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireAsyncSenderTest.cpp
    
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireExpirationTest.cpp
    
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.cpp
    
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSlowListenerTest.cpp
    
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireTempDestinationTest.cpp

Modified: 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireAsyncSenderTest.cpp
URL: 
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireAsyncSenderTest.cpp?rev=709039&r1=709038&r2=709039&view=diff
==============================================================================
--- 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireAsyncSenderTest.cpp
 (original)
+++ 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireAsyncSenderTest.cpp
 Wed Oct 29 16:02:33 2008
@@ -122,6 +122,7 @@
         consumer->setMessageListener( testSupport );
         cms::MessageProducer* producer =
             session->createProducer( topic );
+        producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
 
         // Send some text messages
         testSupport->produceTextMessages(

Modified: 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireExpirationTest.cpp
URL: 
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireExpirationTest.cpp?rev=709039&r1=709038&r2=709039&view=diff
==============================================================================
--- 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireExpirationTest.cpp
 (original)
+++ 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireExpirationTest.cpp
 Wed Oct 29 16:02:33 2008
@@ -135,7 +135,7 @@
                 destination = session->createQueue( topic );
 
                 producer = session->createProducer( destination );
-                producer->setDeliveryMode( DeliveryMode::PERSISTENT );
+                producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
                 producer->setDisableMessageTimeStamp( disableTimeStamps );
 
                 //unsigned long ttt=getcurt();

Modified: 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.cpp
URL: 
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.cpp?rev=709039&r1=709038&r2=709039&view=diff
==============================================================================
--- 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.cpp
 (original)
+++ 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSimpleTest.cpp
 Wed Oct 29 16:02:33 2008
@@ -103,6 +103,7 @@
         consumer->setMessageListener( testSupport );
         cms::MessageProducer* producer =
             session->createProducer( topic );
+        producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
 
         // Send some text messages
         testSupport->produceTextMessages(
@@ -157,6 +158,7 @@
         consumer->setMessageListener( testSupport );
         cms::MessageProducer* producer =
             session->createProducer( topic );
+        producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
 
         // Send some text messages
         testSupport->produceTextMessages(
@@ -209,6 +211,7 @@
         cms::MessageConsumer* consumer =  session->createConsumer( topic );
         consumer->setMessageListener( testSupport );
         cms::MessageProducer* producer = session->createProducer( NULL );
+        producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
 
         cms::TextMessage* textMsg = session->createTextMessage();
 
@@ -258,6 +261,7 @@
         cms::Topic* topic = 
session->createTopic(UUID::randomUUID().toString());
         cms::MessageConsumer* consumer = session->createConsumer( topic );
         cms::MessageProducer* producer = session->createProducer( topic );
+        producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
 
         cms::TextMessage* textMsg = session->createTextMessage();
 
@@ -317,6 +321,7 @@
         cms::MessageConsumer* consumer2 = session2->createConsumer( topic );
 
         cms::MessageProducer* producer = session2->createProducer( topic );
+        producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
 
         cms::TextMessage* textMsg = session2->createTextMessage();
 
@@ -383,6 +388,7 @@
         cms::MessageConsumer* consumer2 = session2->createConsumer( topic );
 
         cms::MessageProducer* producer = session2->createProducer( topic );
+        producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
 
         cms::TextMessage* textMsg = session2->createTextMessage();
 
@@ -444,6 +450,7 @@
         cms::MessageConsumer* consumer = session->createConsumer( topic );
 
         cms::MessageProducer* producer = session->createProducer( topic );
+        producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
 
         cms::TextMessage* textMsg = session->createTextMessage();
 
@@ -512,6 +519,7 @@
             UUID::randomUUID().toString() + "?consumer.prefetchSize=0" );
         cms::MessageConsumer* consumer = session->createConsumer( queue );
         cms::MessageProducer* producer = session->createProducer( queue );
+        producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
 
         cms::TextMessage* textMsg = session->createTextMessage();
 
@@ -556,6 +564,7 @@
         cms::Queue* queue = session->createQueue( 
UUID::randomUUID().toString() );
         cms::MessageConsumer* consumer = session->createConsumer( queue );
         cms::MessageProducer* producer = session->createProducer( queue );
+        producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
 
         unsigned char byteValue = 'A';
         char charValue = 'B';
@@ -642,6 +651,7 @@
         cms::Topic* topic = session->createTopic( 
UUID::randomUUID().toString() );
         cms::MessageConsumer* consumer = session->createConsumer( topic );
         cms::MessageProducer* producer = session->createProducer( topic );
+        producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
 
         unsigned char byteValue = 'A';
         char charValue = 'B';

Modified: 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSlowListenerTest.cpp
URL: 
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSlowListenerTest.cpp?rev=709039&r1=709038&r2=709039&view=diff
==============================================================================
--- 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSlowListenerTest.cpp
 (original)
+++ 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireSlowListenerTest.cpp
 Wed Oct 29 16:02:33 2008
@@ -107,6 +107,7 @@
         cms::Session* session = connection->createSession( 
cms::Session::AUTO_ACKNOWLEDGE );
         cms::Destination* destination = 
session->createTopic(UUID::randomUUID().toString());
         cms::MessageProducer* producer = session->createProducer( destination 
);
+        producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
 
         const unsigned int numConsumers = 5;
         cms::MessageConsumer* consumers[numConsumers];

Modified: 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireTempDestinationTest.cpp
URL: 
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireTempDestinationTest.cpp?rev=709039&r1=709038&r2=709039&view=diff
==============================================================================
--- 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireTempDestinationTest.cpp
 (original)
+++ 
activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire/OpenwireTempDestinationTest.cpp
 Wed Oct 29 16:02:33 2008
@@ -118,6 +118,7 @@
 
         cms::MessageProducer* producer =
             session->createProducer( requestTopic );
+        producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
 
         // Send some bytes messages.
         testSupport->produceTextMessages(
@@ -245,6 +246,8 @@
         if( replyTo != NULL ) {
 
             cms::MessageProducer* producer = session->createProducer( replyTo 
);
+            producer->setDeliveryMode( DeliveryMode::NON_PERSISTENT );
+
             cms::Message* response = session->createMessage();
 
             // Send it back to the replyTo Destination

svn commit: r709039 - in /activemq/activemq-cpp/trunk/src/test-integration/integration/connector/openwire: OpenwireAsyncSenderTest.cpp OpenwireExpirationTest.cpp OpenwireSimpleTest.cpp OpenwireSlowListenerTest.cpp OpenwireTempDestinationTest.cpp

Reply via email to