Skip to content

Commit 6cff782

Browse files
Add a basic test for Subscription#Ack
1 parent 61f1a94 commit 6cff782

File tree

1 file changed

+15
-0
lines changed

1 file changed

+15
-0
lines changed

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

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,5 +75,20 @@ public void TestChannelClosureIsObservableOnSubscription()
7575
BasicDeliverEventArgs r3;
7676
Assert.IsFalse(sub.Next(100, out r3));
7777
}
78+
79+
[Test]
80+
public void TestSubscriptionAck()
81+
{
82+
Model.BasicQos(0, 1, false);
83+
string q = Model.QueueDeclare();
84+
Subscription sub = new Subscription(Model, q, false);
85+
86+
Model.BasicPublish("", q, null, enc.GetBytes("a message"));
87+
BasicDeliverEventArgs res = sub.Next();
88+
Assert.IsNotNull(res);
89+
sub.Ack();
90+
QueueDeclareOk ok = Model.QueueDeclarePassive(q);
91+
Assert.AreEqual(0, ok.MessageCount);
92+
}
7893
}
7994
}

0 commit comments

Comments
 (0)