Author: tabish
Date: Mon Nov 30 19:24:18 2009
New Revision: 885548
URL: http://svn.apache.org/viewvc?rev=885548&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQNET-215
Adds additional tests from the user supplied test patch.
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/IndividualAckTest.cs
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/IndividualAckTest.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/IndividualAckTest.cs?rev=885548&r1=885547&r2=885548&view=diff
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/IndividualAckTest.cs
(original)
+++
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/IndividualAckTest.cs
Mon Nov 30 19:24:18 2009
@@ -182,6 +182,84 @@
Assert.IsNull(fetchedMessage2);
consumer.Close();
}
+
+ [Test]
+ public void TestManyMessageAckedAfterMessageConsumption()
+ {
+ int messageCount = 20;
+ IMessage msg;
+
+ ISession session =
connection.CreateSession(AcknowledgementMode.IndividualAcknowledge);
+ ITemporaryQueue queue = session.CreateTemporaryQueue();
+ IMessageProducer producer = session.CreateProducer(queue);
+ for(int i = 0; i < messageCount; i++)
+ {
+ msg = session.CreateTextMessage("msg" + i);
+ producer.Send(msg);
+ }
+
+ // Consume the message...
+ IMessageConsumer consumer = session.CreateConsumer(queue);
+ for(int i = 0; i < messageCount; i++)
+ {
+ msg = consumer.Receive(TimeSpan.FromMilliseconds(1000));
+ Assert.IsNotNull(msg);
+ msg.Acknowledge();
+ }
+ msg = consumer.Receive(TimeSpan.FromMilliseconds(1000));
+ Assert.IsNull(msg);
+
+ // Reset the session.
+ session.Close();
+ session =
connection.CreateSession(AcknowledgementMode.IndividualAcknowledge);
+
+ // Attempt to Consume the message...
+ consumer = session.CreateConsumer(queue);
+ msg = consumer.Receive(TimeSpan.FromMilliseconds(1000));
+ Assert.IsNull(msg);
+ session.Close();
+ }
+ [Test]
+ public void TestManyMessageAckedAfterAllConsumption()
+ {
+ int messageCount = 20;
+ IMessage msg;
+
+ ISession session =
connection.CreateSession(AcknowledgementMode.IndividualAcknowledge);
+ ITemporaryQueue queue = session.CreateTemporaryQueue();
+ IMessageProducer producer = session.CreateProducer(queue);
+ for(int i = 0; i < messageCount; i++)
+ {
+ msg = session.CreateTextMessage("msg" + i);
+ producer.Send(msg);
+ }
+
+ // Consume the message...
+ IMessageConsumer consumer = session.CreateConsumer(queue);
+ IMessage[] consumedMessages = new IMessage[messageCount];
+ for(int i = 0; i < messageCount; i++)
+ {
+ msg = consumer.Receive(TimeSpan.FromMilliseconds(1000));
+ Assert.IsNotNull(msg);
+ consumedMessages[i] = msg;
+ }
+ for(int i = 0; i < messageCount; i++)
+ {
+ consumedMessages[i].Acknowledge();
+ }
+ msg = consumer.Receive(TimeSpan.FromMilliseconds(1000));
+ Assert.IsNull(msg);
+
+ // Reset the session.
+ session.Close();
+ session =
connection.CreateSession(AcknowledgementMode.IndividualAcknowledge);
+
+ // Attempt to Consume the message...
+ consumer = session.CreateConsumer(queue);
+ msg = consumer.Receive(TimeSpan.FromMilliseconds(1000));
+ Assert.IsNull(msg);
+ session.Close();
+ }
}
}
