Skip to content

Commit c4869d9

Browse files
committed
Remove unneeded stop work
1 parent ea3c5c4 commit c4869d9

File tree

2 files changed

+0
-16
lines changed

2 files changed

+0
-16
lines changed

projects/client/RabbitMQ.Client/src/client/impl/AsyncConsumerWorkService.cs

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -28,14 +28,6 @@ public void Stop(IModel model)
2828
}
2929
}
3030

31-
public void Stop()
32-
{
33-
foreach (IModel model in _workPools.Keys)
34-
{
35-
Stop(model);
36-
}
37-
}
38-
3931
class WorkPool
4032
{
4133
readonly ConcurrentQueue<Work> _workQueue;

projects/client/RabbitMQ.Client/src/client/impl/ConsumerWorkService.cs

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -29,14 +29,6 @@ public void StopWork(IModel model)
2929
}
3030
}
3131

32-
public void StopWork()
33-
{
34-
foreach (IModel model in _workPools.Keys)
35-
{
36-
StopWork(model);
37-
}
38-
}
39-
4032
class WorkPool
4133
{
4234
readonly ConcurrentQueue<Action> _actions;

0 commit comments

Comments
 (0)