Try to fixes RabbitMQ BasicConsume TimeOutException . #1405

dotnetcore · Sep 21, 2023 · c63fa87 · c63fa87
1 parent adbe7bf
commit c63fa87
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 4 deletions.
diff --git a/src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs b/src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs
@@ -67,10 +67,16 @@ public void Listening(TimeSpan timeout, CancellationToken cancellationToken)
         consumer.ConsumerCancelled += OnConsumerConsumerCancelled;
 
         if (_rabbitMQOptions.BasicQosOptions != null)
-            _channel?.BasicQos(0, _rabbitMQOptions.BasicQosOptions.PrefetchCount,
-                _rabbitMQOptions.BasicQosOptions.Global);
+            _channel?.BasicQos(0, _rabbitMQOptions.BasicQosOptions.PrefetchCount, _rabbitMQOptions.BasicQosOptions.Global);
 
-        _channel.BasicConsume(_queueName, false, consumer);
+        try
+        {
+            _channel.BasicConsume(_queueName, false, consumer);
+        }
+        catch (TimeoutException ex)
+        {
+            OnConsumerShutdown(null, new ShutdownEventArgs(ShutdownInitiator.Application, 0, ex.Message + "-->" + nameof(_channel.BasicConsume)));
+        }
 
         while (true)
         {
@@ -121,7 +127,14 @@ public void Connect()
                 if (!string.IsNullOrEmpty(_rabbitMQOptions.QueueArguments.QueueType))
                     arguments.Add("x-queue-type", _rabbitMQOptions.QueueArguments.QueueType);
 
-                _channel.QueueDeclare(_queueName, true, false, false, arguments);
+                try
+                {
+                    _channel.QueueDeclare(_queueName, true, false, false, arguments);
+                }
+                catch (TimeoutException ex)
+                {
+                    OnConsumerShutdown(null, new ShutdownEventArgs(ShutdownInitiator.Application, 0, ex.Message + "-->" + nameof(_channel.QueueDeclare)));
+                }
             }
         }
     }

diff --git a/...tCore.CAP/Internal/SnowflakeId.Default.cs → ...Core.CAP/Internal/ISnowflakeId.Default.cs b/...tCore.CAP/Internal/SnowflakeId.Default.cs → ...Core.CAP/Internal/ISnowflakeId.Default.cs