activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r984245 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/NMSConnectionFactoryTest.cs
Date Tue, 10 Aug 2010 22:25:23 GMT
Author: tabish
Date: Tue Aug 10 22:25:22 2010
New Revision: 984245

URL: http://svn.apache.org/viewvc?rev=984245&view=rev
Log:
Fix the recently "fixed" test :)

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

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/NMSConnectionFactoryTest.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/NMSConnectionFactoryTest.cs?rev=984245&r1=984244&r2=984245&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/NMSConnectionFactoryTest.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/NMSConnectionFactoryTest.cs
Tue Aug 10 22:25:22 2010
@@ -121,12 +121,13 @@ namespace Apache.NMS.ActiveMQ.Test
 		[TestCase(112, 212, 312, 412, 512)]
         public void TestURIForPrefetchHandling(int queuePreFetch, int queueBrowserPrefetch,
int topicPrefetch, int durableTopicPrefetch, int maximumPendingMessageLimit)
         {
-            string testuri = string.Format("activemq:tcp://${activemqhost}:61616" +
-                          "?nms.PrefetchPolicy.queuePrefetch=" + queuePreFetch +
-                          "&nms.PrefetchPolicy.queueBrowserPrefetch=" + queueBrowserPrefetch
+
-                          "&nms.PrefetchPolicy.topicPrefetch=" + topicPrefetch +
-                          "&nms.PrefetchPolicy.durableTopicPrefetch=" + durableTopicPrefetch
+
-                          "&nms.PrefetchPolicy.maximumPendingMessageLimit="+ maximumPendingMessageLimit);
+            string testuri = string.Format("activemq:tcp://${{activemqhost}}:61616" +
+                          				   "?nms.PrefetchPolicy.queuePrefetch={0}" +
+                                           "&nms.PrefetchPolicy.queueBrowserPrefetch={1}"
+
+                                           "&nms.PrefetchPolicy.topicPrefetch={2}" +
+                                           "&nms.PrefetchPolicy.durableTopicPrefetch={3}"
+
+                                           "&nms.PrefetchPolicy.maximumPendingMessageLimit={4}",
+			                               queuePreFetch, queueBrowserPrefetch, topicPrefetch, durableTopicPrefetch,
maximumPendingMessageLimit);
 
             NMSConnectionFactory factory = new NMSConnectionFactory(NMSTestSupport.ReplaceEnvVar(testuri));
 
@@ -137,11 +138,11 @@ namespace Apache.NMS.ActiveMQ.Test
                 Assert.IsNotNull(connection);
 
                 Connection amqConnection = connection as Connection;
-                Assert.AreEqual(1, amqConnection.PrefetchPolicy.QueuePrefetch);
-                Assert.AreEqual(2, amqConnection.PrefetchPolicy.QueueBrowserPrefetch);
-                Assert.AreEqual(3, amqConnection.PrefetchPolicy.TopicPrefetch);
-                Assert.AreEqual(4, amqConnection.PrefetchPolicy.DurableTopicPrefetch);
-                Assert.AreEqual(5, amqConnection.PrefetchPolicy.MaximumPendingMessageLimit);
+                Assert.AreEqual(queuePreFetch, amqConnection.PrefetchPolicy.QueuePrefetch);
+                Assert.AreEqual(queueBrowserPrefetch, amqConnection.PrefetchPolicy.QueueBrowserPrefetch);
+                Assert.AreEqual(topicPrefetch, amqConnection.PrefetchPolicy.TopicPrefetch);
+                Assert.AreEqual(durableTopicPrefetch, amqConnection.PrefetchPolicy.DurableTopicPrefetch);
+                Assert.AreEqual(maximumPendingMessageLimit, amqConnection.PrefetchPolicy.MaximumPendingMessageLimit);
             }
         }
     }



Mime
View raw message