Skip to content

Commit 932443d

Browse files
Naming
1 parent 41a0781 commit 932443d

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

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

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -180,19 +180,19 @@ public void TestChannelShutdownDoesNotShutDownDispatcher()
180180
private class ShutdownLatchConsumer : DefaultBasicConsumer
181181
{
182182
public ManualResetEvent Latch { get; private set; }
183-
public ManualResetEvent LatchDuplicate { get; private set; }
183+
public ManualResetEvent DuplicateLatch { get; private set; }
184184

185-
public ShutdownLatchConsumer(ManualResetEvent latch, ManualResetEvent latchDuplicate)
185+
public ShutdownLatchConsumer(ManualResetEvent latch, ManualResetEvent duplicateLatch)
186186
{
187187
this.Latch = latch;
188-
this.LatchDuplicate = latchDuplicate;
188+
this.DuplicateLatch = duplicateLatch;
189189
}
190190

191191
public override void HandleModelShutdown(object model, ShutdownEventArgs reason)
192192
{
193-
// If Latch is already set - event is duplicate
193+
// keep track of duplicates
194194
if (this.Latch.WaitOne(0)){
195-
this.LatchDuplicate.Set();
195+
this.DuplicateLatch.Set();
196196
} else {
197197
this.Latch.Set();
198198
}
@@ -203,15 +203,15 @@ public override void HandleModelShutdown(object model, ShutdownEventArgs reason)
203203
public void TestModelShutdownHandler()
204204
{
205205
var latch = new ManualResetEvent(false);
206-
var latchDuplicate = new ManualResetEvent(false);
206+
var duplicateLatch = new ManualResetEvent(false);
207207
var q = this.Model.QueueDeclare().QueueName;
208-
var c = new ShutdownLatchConsumer(latch, latchDuplicate);
208+
var c = new ShutdownLatchConsumer(latch, duplicateLatch);
209209

210210
this.Model.BasicConsume(queue: q, noAck: true, consumer: c);
211211
this.Model.Close();
212212
Wait(latch, TimeSpan.FromSeconds(5));
213-
Assert.IsFalse(latchDuplicate.WaitOne(TimeSpan.FromSeconds(5)),
214-
"duplicate events");
213+
Assert.IsFalse(duplicateLatch.WaitOne(TimeSpan.FromSeconds(5)),
214+
"event handler fired more than once");
215215
}
216216
}
217217
}

0 commit comments

Comments
 (0)