diff options
| author | Aidan Skinner <aidan@apache.org> | 2008-05-08 15:09:17 +0000 |
|---|---|---|
| committer | Aidan Skinner <aidan@apache.org> | 2008-05-08 15:09:17 +0000 |
| commit | 8f39d1955d3ed7bf62e44beb561d8ede72df9ec6 (patch) | |
| tree | 2a9a7be63b7ef014cba0ee6743c412e3fe6532e2 /dotnet | |
| parent | e1a8ebc7eddcee2ebb1c28cebba2bf13bb75ce34 (diff) | |
| download | qpid-python-8f39d1955d3ed7bf62e44beb561d8ede72df9ec6.tar.gz | |
QPID-1038 add a mixed send/recieve/rollback test
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@654545 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'dotnet')
| -rw-r--r-- | dotnet/Qpid.Integration.Tests/testcases/CommitRollbackTest.cs | 19 |
1 files changed, 18 insertions, 1 deletions
diff --git a/dotnet/Qpid.Integration.Tests/testcases/CommitRollbackTest.cs b/dotnet/Qpid.Integration.Tests/testcases/CommitRollbackTest.cs index 1951a8a171..3224d2cbd2 100644 --- a/dotnet/Qpid.Integration.Tests/testcases/CommitRollbackTest.cs +++ b/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]);
+
+ }
}
}
|