Fixed connection dispose bug before connection connected.

bec28ca3 · Savorboard · 226d42a8 · bec28ca3 · bec28ca3
Commit bec28ca3 authored Jul 24, 2019 by Savorboard
Show whitespace changes
Inline Side-by-side

Showing with 3 additions and 3 deletions

KafkaConsumerClient.cs src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs +1 -1

RabbitMQConsumerClient.cs src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs +2 -2

No files found.
--- a/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs
+++ b/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs
@@ -75,7 +75,7 @@ namespace DotNetCore.CAP.Kafka

        public void Dispose()
        {
-            _consumerClient.Dispose();
+            _consumerClient?.Dispose();
        }

        #region private methods

--- a/src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs
+++ b/src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs
@@ -89,8 +89,8 @@ namespace DotNetCore.CAP.RabbitMQ

        public void Dispose()
        {
-            _channel.Dispose();
-            _connection.Dispose();
+            _channel?.Dispose();
+            _connection?.Dispose();
        }

        #region events