Giving the server a little more time to restart the RabbitMQ server.

Stefán J. Sigurðarson · Stefán J. Sigurðarson · commit 46ed915190b8 · 2020-10-20T15:20:22.000Z
diff --git a/projects/RabbitMQ.Client/client/impl/SocketFrameHandler.cs b/projects/RabbitMQ.Client/client/impl/SocketFrameHandler.cs
@@ -99,7 +99,7 @@ public SocketFrameHandler(AmqpTcpEndpoint endpoint, Func<AddressFamily, ITcpClie
                 {
                     AllowSynchronousContinuations = true,
                     SingleReader = true,
-                    SingleWriter = false
+                    SingleWriter = true
                 });
 
             _channelReader = channel.Reader;
diff --git a/projects/Unit/RabbitMQCtl.cs b/projects/Unit/RabbitMQCtl.cs
@@ -308,7 +308,7 @@ public static void CloseConnection(string pid)
         public static void RestartRabbitMQ()
         {
             StopRabbitMQ();
-            Thread.Sleep(500);
+            Thread.Sleep(1000);
             StartRabbitMQ();
         }
 

Original file line number	Diff line number	Diff line change
`@@ -99,7 +99,7 @@ public SocketFrameHandler(AmqpTcpEndpoint endpoint, Func<AddressFamily, ITcpClie`
`99`	`99`	`{`
`100`	`100`	`AllowSynchronousContinuations = true,`
`101`	`101`	`SingleReader = true,`
`102`		`- SingleWriter = false`
	`102`	`+ SingleWriter = true`
`103`	`103`	`});`
`104`	`104`
`105`	`105`	`_channelReader = channel.Reader;`
Original file line number	Diff line number	Diff line change
`@@ -308,7 +308,7 @@ public static void CloseConnection(string pid)`
`308`	`308`	`public static void RestartRabbitMQ()`
`309`	`309`	`{`
`310`	`310`	`StopRabbitMQ();`
`311`		`- Thread.Sleep(500);`
	`311`	`+ Thread.Sleep(1000);`
`312`	`312`	`StartRabbitMQ();`
`313`	`313`	`}`
`314`	`314`