Merge pull request #773 from danielmarbach/model-shutdown

lukebakken · web-flow · commit c0178a2757f0 · 2020-03-25T14:23:19.000-07:00
Schedule instead of GetAwaiter().GetResult()
diff --git a/projects/client/RabbitMQ.Client/src/client/impl/AsyncConsumerDispatcher.cs b/projects/client/RabbitMQ.Client/src/client/impl/AsyncConsumerDispatcher.cs
@@ -61,7 +61,7 @@ public void HandleBasicCancel(IBasicConsumer consumer, string consumerTag)
         public void HandleModelShutdown(IBasicConsumer consumer, ShutdownEventArgs reason)
         {
             // the only case where we ignore the shutdown flag.
-            new ModelShutdown(consumer, reason).Execute(_model).GetAwaiter().GetResult();
+            Schedule(new ModelShutdown(consumer, reason));
         }
 
         private void ScheduleUnlessShuttingDown<TWork>(TWork work)

Original file line number	Diff line number	Diff line change
`@@ -61,7 +61,7 @@ public void HandleBasicCancel(IBasicConsumer consumer, string consumerTag)`
`61`	`61`	`public void HandleModelShutdown(IBasicConsumer consumer, ShutdownEventArgs reason)`
`62`	`62`	`{`
`63`	`63`	`// the only case where we ignore the shutdown flag.`
`64`		`- new ModelShutdown(consumer, reason).Execute(_model).GetAwaiter().GetResult();`
	`64`	`+ Schedule(new ModelShutdown(consumer, reason));`
`65`	`65`	`}`
`66`	`66`
`67`	`67`	`private void ScheduleUnlessShuttingDown<TWork>(TWork work)`