Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Content-Type: text/plain; charset="utf-8"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
Subject: svn commit: r830263 -
 /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/ZeroPrefetchConsumerTest.cs
Date: Tue, 27 Oct 2009 17:44:36 -0000
To: commits@activemq.apache.org
From: tabish@apache.org
Message-Id: <20091027174436.3662B238888A@eris.apache.org>

Author: tabish
Date: Tue Oct 27 17:44:35 2009
New Revision: 830263

URL: http://svn.apache.org/viewvc?rev=830263&view=rev
Log:
* ZeroPrefetchConsumerTest.cs: 

Adds new test case for Consumers with a Prefetch size of zero.

Added:
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/ZeroPrefetchConsumerTest.cs   (with props)

Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/ZeroPrefetchConsumerTest.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/ZeroPrefetchConsumerTest.cs?rev=830263&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/ZeroPrefetchConsumerTest.cs (added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/ZeroPrefetchConsumerTest.cs Tue Oct 27 17:44:35 2009
@@ -0,0 +1,183 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+using System;
+using System.Threading;
+using Apache.NMS;
+using Apache.NMS.Util;
+using Apache.NMS.ActiveMQ.Commands;
+using NUnit.Framework;
+using NUnit.Framework.Extensions;
+
+namespace Apache.NMS.Test
+{    
+    [TestFixture]
+    public class ZeroPrefetchConsumerTest : NMSTestSupport
+    {
+        protected IConnection connection;
+        protected IQueue queue;
+
+        public void OnMessageFailTest(IMessage message)
+        {
+        }
+
+        [Test]
+        public void TestCannotUseMessageListener()
+        {
+            ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge);
+            IMessageConsumer consumer = session.CreateConsumer(queue);
+    
+            try 
+            {
+                consumer.Listener += new MessageListener(OnMessageFailTest);
+                Assert.Fail("Should have thrown JMSException as we cannot use MessageListener with zero prefetch");
+            } 
+            catch(NMSException) 
+            {
+            }
+        }
+
+        [Test]
+        public void TestPullConsumerWorks() 
+        {
+            ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge);
+    
+            IMessageProducer producer = session.CreateProducer(queue);
+            producer.Send(session.CreateTextMessage("Hello World!"));
+    
+            // now lets Receive it
+            IMessageConsumer consumer = session.CreateConsumer(queue);
+            IMessage answer = consumer.Receive(TimeSpan.FromMilliseconds(5000));
+            Assert.IsNotNull(answer, "Should have received a message!");
+            // check if method will return at all and will return a null
+            answer = consumer.Receive(TimeSpan.FromMilliseconds(1));
+            Assert.IsNull(answer, "Should have not received a message!");
+            answer = consumer.ReceiveNoWait();
+            Assert.IsNull(answer, "Should have not received a message!");
+        }
+
+        [RowTest]
+        [Row(AcknowledgementMode.AutoAcknowledge)]
+        [Row(AcknowledgementMode.Transactional)]        
+        public void TestIdleConsumer(AcknowledgementMode ackMode) 
+        {
+            ISession session = connection.CreateSession(ackMode);
+    
+            IMessageProducer producer = session.CreateProducer(queue);
+            producer.Send(session.CreateTextMessage("Msg1"));
+            producer.Send(session.CreateTextMessage("Msg2"));
+            if(session.Transacted)
+            {
+                session.Commit();
+            }
+
+            // now lets Receive it
+            IMessageConsumer consumer = session.CreateConsumer(queue);
+            
+            session.CreateConsumer(queue);
+            ITextMessage answer = (ITextMessage)consumer.Receive(TimeSpan.FromMilliseconds(5000));
+            Assert.AreEqual(answer.Text, "Msg1", "Should have received a message!");
+            
+            if(session.Transacted)
+            {
+                session.Commit();
+            }
+            
+            // this call would return null if prefetchSize > 0
+            answer = (ITextMessage)consumer.Receive(TimeSpan.FromMilliseconds(5000));
+            Assert.AreEqual(answer.Text, "Msg2", "Should have received a message!");
+            if(session.Transacted)
+            {
+                session.Commit();
+            }
+            answer = (ITextMessage)consumer.ReceiveNoWait();
+            Assert.IsNull(answer, "Should have not received a message!");
+        }
+    
+        [RowTest]
+        [Row(AcknowledgementMode.AutoAcknowledge)]
+        [Row(AcknowledgementMode.Transactional)]  
+        public void TestRecvRecvCommit(AcknowledgementMode ackMode)
+        {
+            ISession session = connection.CreateSession(ackMode);
+    
+            IMessageProducer producer = session.CreateProducer(queue);
+            producer.Send(session.CreateTextMessage("Msg1"));
+            producer.Send(session.CreateTextMessage("Msg2"));
+            if(session.Transacted)
+            {
+                session.Commit();
+            }
+            // now lets Receive it
+            IMessageConsumer consumer = session.CreateConsumer(queue);
+            ITextMessage answer = (ITextMessage)consumer.ReceiveNoWait();
+            Assert.AreEqual(answer.Text, "Msg1", "Should have received a message!");
+            answer = (ITextMessage)consumer.ReceiveNoWait();
+            Assert.AreEqual(answer.Text, "Msg2", "Should have received a message!");
+            if(session.Transacted)
+            {
+                session.Commit();
+            }
+            answer = (ITextMessage)consumer.ReceiveNoWait();
+            Assert.IsNull(answer, "Should have not received a message!");
+        }
+
+        [Test]
+        public void TestTwoConsumers() 
+        {
+            ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge);
+    
+            IMessageProducer producer = session.CreateProducer(queue);
+            producer.Send(session.CreateTextMessage("Msg1"));
+            producer.Send(session.CreateTextMessage("Msg2"));
+    
+            // now lets Receive it
+            IMessageConsumer consumer1 = session.CreateConsumer(queue);
+            IMessageConsumer consumer2 = session.CreateConsumer(queue);
+            ITextMessage answer = (ITextMessage)consumer1.ReceiveNoWait();
+            Assert.AreEqual(answer.Text, "Msg1", "Should have received a message!");
+            answer = (ITextMessage)consumer2.ReceiveNoWait();
+            Assert.AreEqual(answer.Text, "Msg2", "Should have received a message!");
+    
+            answer = (ITextMessage)consumer2.ReceiveNoWait();
+            Assert.IsNull(answer, "Should have not received a message!");
+        }
+
+        [SetUp]
+        public override void SetUp()
+        {
+            base.SetUp();
+    
+            connection = CreateConnection();
+            connection.Start();
+            queue = CreateQueue();            
+        }
+
+        [TearDown]
+        public override void TearDown()
+        {
+            connection.Close();
+            base.TearDown();
+        }
+        
+        protected IQueue CreateQueue() 
+        {
+            return new ActiveMQQueue( "ZeroPrefetchConsumerTest?consumer.prefetchSize=0");
+        }
+        
+    }
+}

Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/ZeroPrefetchConsumerTest.cs
------------------------------------------------------------------------------
    svn:eol-style = native