activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r829841 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/ExclusiveConsumerTest.cs
Date Mon, 26 Oct 2009 15:53:40 GMT
Author: tabish
Date: Mon Oct 26 15:53:40 2009
New Revision: 829841

URL: http://svn.apache.org/viewvc?rev=829841&view=rev
Log:
Make the delivery mode on the producers non-persistent.

Modified:
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/ExclusiveConsumerTest.cs

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/ExclusiveConsumerTest.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/ExclusiveConsumerTest.cs?rev=829841&r1=829840&r2=829841&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/ExclusiveConsumerTest.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/ExclusiveConsumerTest.cs
Mon Oct 26 15:53:40 2009
@@ -68,6 +68,7 @@
                 IMessageProducer producer = senderSession.CreateProducer(senderQueue);
     
                 IMessage msg = senderSession.CreateTextMessage("test");
+                producer.DeliveryMode = MsgDeliveryMode.NonPersistent;
                 producer.Send(msg);
                 Thread.Sleep(500);
 
@@ -109,6 +110,7 @@
                 IMessageProducer producer = senderSession.CreateProducer(senderQueue);
     
                 IMessage msg = senderSession.CreateTextMessage("test");
+                producer.DeliveryMode = MsgDeliveryMode.NonPersistent;
                 producer.Send(msg);
                 Thread.Sleep(500);
     
@@ -153,6 +155,7 @@
                 ActiveMQQueue senderQueue = new ActiveMQQueue("TEST.QUEUE2");
     
                 IMessageProducer producer = senderSession.CreateProducer(senderQueue);
+                producer.DeliveryMode = MsgDeliveryMode.NonPersistent;
     
                 IMessage msg = senderSession.CreateTextMessage("test");
                 producer.Send(msg);
@@ -211,7 +214,8 @@
                 ActiveMQQueue senderQueue = new ActiveMQQueue("TEST.QUEUE6");
     
                 IMessageProducer producer = senderSession.CreateProducer(senderQueue);
-    
+                producer.DeliveryMode = MsgDeliveryMode.NonPersistent;
+
                 IMessage msg = senderSession.CreateTextMessage("test");
                 producer.Send(msg);
                 Thread.Sleep(500);
@@ -265,6 +269,7 @@
                 ActiveMQQueue senderQueue = new ActiveMQQueue("TEST.QUEUE3");
     
                 IMessageProducer producer = senderSession.CreateProducer(senderQueue);
+                producer.DeliveryMode = MsgDeliveryMode.NonPersistent;
     
                 IMessage msg = senderSession.CreateTextMessage("test");
                 producer.Send(msg);
@@ -317,6 +322,7 @@
                 ActiveMQQueue senderQueue = new ActiveMQQueue("TEST.QUEUE4");
     
                 IMessageProducer producer = senderSession.CreateProducer(senderQueue);
+                producer.DeliveryMode = MsgDeliveryMode.NonPersistent;
     
                 IMessage msg = senderSession.CreateTextMessage("test");
                 producer.Send(msg);



Mime
View raw message