One more test

Author: michaelklishin

projects/client/Unit/src/unit/TestPublisherConfirms.cs

@@ -40,6 +40,7 @@
 
 using NUnit.Framework;
 using System;
+using System.Threading;
 using RabbitMQ.Client;
 
 namespace RabbitMQ.Client.Unit
@@ -65,6 +66,43 @@ public void TestWaitForConfirmsWithTimeout()
             }); ;
         }
 
+        [Test]
+        public void TestWaitForConfirmsWithEvents()
+        {
+            var ch = Conn.CreateModel();
+            ch.ConfirmSelect();
+
+            var q = ch.QueueDeclare().QueueName;
+            var n = 200;
+            // number of event handler invocations
+            var c = 0;
+
+            ch.BasicAcks += (_, args) =>
+            {
+                Interlocked.Increment(ref c);
+            };
+            try
+            {
+                for (int i = 0; i < n; i++)
+                {
+                    ch.BasicPublish("", q, null, encoding.GetBytes("msg"));
+                }
+                Thread.Sleep(TimeSpan.FromSeconds(1));
+                ch.WaitForConfirms(TimeSpan.FromSeconds(5));
+
+                // Note: number of event invocations is not guaranteed
+                // to be equal to N because acks can be batched,
+                // so we primarily care about event handlers being invoked
+                // in this test
+                Assert.IsTrue(c > 20);
+            }
+            finally
+            {
+                ch.QueueDelete(q);
+                ch.Close();
+            }
+        }
+
         protected void TestWaitForConfirms(int numberOfMessagesToPublish, Action<IModel> fn)
         {
             var ch = Conn.CreateModel();