activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r737139 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/OpenWire/PrefetchSizeZeroTest.cs
Date Fri, 23 Jan 2009 18:40:21 GMT
Author: tabish
Date: Fri Jan 23 10:40:21 2009
New Revision: 737139

URL: http://svn.apache.org/viewvc?rev=737139&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQNET-106

Tweaks to the test case to ensure prefetch is set to zero.

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

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/OpenWire/PrefetchSizeZeroTest.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/OpenWire/PrefetchSizeZeroTest.cs?rev=737139&r1=737138&r2=737139&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/OpenWire/PrefetchSizeZeroTest.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/OpenWire/PrefetchSizeZeroTest.cs
Fri Jan 23 10:40:21 2009
@@ -14,60 +14,59 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
-using System;
-using NUnit.Framework;
+
+using System;
+using NUnit.Framework;
 using Apache.NMS.Util;
+using Apache.NMS.ActiveMQ;
 using NUnit.Framework.Extensions;
 using System.Threading;
-
-namespace Apache.NMS.Test
-{
-	[TestFixture]
-	public class PrefetchSizeZeroTest : NMSTestSupport
-	{	
-        protected static string DESTINATION_NAME = "TestPrefetchSizeZero?consumer.prefetchSize=0";
-			
-		[Test, Explicit]
-		public void TestZeroPrefetchSize()
-		{
+
+namespace Apache.NMS.Test
+{
+	[TestFixture]
+	public class PrefetchSizeZeroTest : NMSTestSupport
+	{	
+        protected static string DESTINATION_NAME = "TestPrefetchSizeZero";
+			
+		[Test, Explicit]
+		public void TestZeroPrefetchSize()
+		{
 			using(IConnection connection = CreateConnection())
 			{
 				connection.Start();
-				using(ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
+				using(Session session = (Session)connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
 				{
 					IDestination destination = SessionUtil.GetDestination(session, DESTINATION_NAME);
+                    session.PrefetchSize = 0;
 					using(IMessageConsumer consumer = session.CreateConsumer(destination))
 					using(IMessageProducer producer = session.CreateProducer(destination))
 					{
 						SendMessage(producer);
                         SendMessage(producer);
 
-						IMessage receivedMsg = consumer.Receive(TimeSpan.FromSeconds(5));
-                        Assert.IsNotNull(receivedMsg);
+						IMessage receivedMsg = consumer.Receive(TimeSpan.FromSeconds(5));
+                        Assert.IsNotNull(receivedMsg);
                         receivedMsg = consumer.Receive(TimeSpan.FromSeconds(5));
-                        Assert.IsNotNull(receivedMsg);
-						receivedMsg = consumer.Receive(TimeSpan.FromSeconds(5));
-                        Assert.IsNull(receivedMsg);
-                        
-						// Go inactive...
-						Thread.Sleep(TimeSpan.FromSeconds(10));
+                        Assert.IsNotNull(receivedMsg);
+						receivedMsg = consumer.Receive(TimeSpan.FromSeconds(5));
+                        Assert.IsNull(receivedMsg);
 
 						// Send another message.
 						SendMessage(producer);
-						receivedMsg = consumer.Receive(TimeSpan.FromSeconds(5));
-						Assert.IsNotNull(receivedMsg);
+                        receivedMsg = consumer.Receive(TimeSpan.FromSeconds(5));
+						Assert.IsNotNull(receivedMsg);
                    
 					}
 				}
-			}
-		}
-	
+			}
+		}
+	
 		protected void SendMessage(IMessageProducer producer)
 		{
 			IMessage request = producer.CreateMessage();
 			request.NMSType = "Test";
 			producer.Send(request);
-		}
-	}
-}
+		}
+	}
+}



Mime
View raw message