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

1 files changed, 18 insertions, 1 deletions

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]);

+            

+        }

     }

 }