From 8316d2b0c1affdee50bee3ed8a6297a582f38c77 Mon Sep 17 00:00:00 2001 From: Aidan Skinner Date: Thu, 8 May 2008 15:09:17 +0000 Subject: QPID-1038 add a mixed send/recieve/rollback test git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@654545 13f79535-47bb-0310-9956-ffa450edef68 --- .../testcases/CommitRollbackTest.cs | 19 ++++++++++++++++++- 1 file changed, 18 insertions(+), 1 deletion(-) diff --git a/qpid/dotnet/Qpid.Integration.Tests/testcases/CommitRollbackTest.cs b/qpid/dotnet/Qpid.Integration.Tests/testcases/CommitRollbackTest.cs index 1951a8a171..3224d2cbd2 100644 --- a/qpid/dotnet/Qpid.Integration.Tests/testcases/CommitRollbackTest.cs +++ b/qpid/dotnet/Qpid.Integration.Tests/testcases/CommitRollbackTest.cs @@ -58,7 +58,7 @@ namespace Apache.Qpid.Integration.Tests.testcases // Create one producer and one consumer, p2p, tx, consumer with queue bound to producers routing key. SetUpEndPoint(0, true, false, TEST_ROUTING_KEY + testId, AcknowledgeMode.AutoAcknowledge, true, ExchangeNameDefaults.DIRECT, true, false, null); - SetUpEndPoint(1, false, true, TEST_ROUTING_KEY + testId, AcknowledgeMode.AutoAcknowledge, true, ExchangeNameDefaults.DIRECT, + SetUpEndPoint(1, true, true, TEST_ROUTING_KEY + testId, AcknowledgeMode.AutoAcknowledge, true, ExchangeNameDefaults.DIRECT, true, false, null); } @@ -172,5 +172,22 @@ namespace Apache.Qpid.Integration.Tests.testcases ConsumeNMessagesOnly(1, "E", testConsumer[1]); } + + [Test] + public void TestReceiveAndSendRollback() + { + // Send messages + testProducer[0].Send(testChannel[0].CreateTextMessage("F")); + testChannel[0].Commit(); + + // Try to receive messages. + ConsumeNMessagesOnly(1, "F", testConsumer[1]); + testProducer[1].Send(testChannel[1].CreateTextMessage("G")); + testChannel[1].Rollback(); + + // Try to receive messages. + ConsumeNMessagesOnly(1, "F", testConsumer[1]); + + } } } -- cgit v1.2.1