fix: RabbitMQ connection not closing

src/Services/RabbitMQService.cs

@@ -9,6 +9,7 @@ namespace Microsoft.Azure.WebJobs.Extensions.RabbitMQ
     internal sealed class RabbitMQService : IRabbitMQService
     {
         private readonly IRabbitMQModel _rabbitMQModel;
+        private readonly IConnection _connection;
         private readonly IModel _model;
         private readonly IBasicPublishBatch _batch;
         private readonly string _connectionString;
@@ -27,14 +28,14 @@ public RabbitMQService(string connectionString, string hostName, string userName
             _port = port;
 
             ConnectionFactory connectionFactory = GetConnectionFactory(_connectionString, _hostName, _userName, _password, _port);
-
-            _model = connectionFactory.CreateConnection().CreateModel();
+            _connection = connectionFactory.CreateConnection();
+            _model = _connection.CreateModel();
         }
 
         public RabbitMQService(string connectionString, string hostName, string queueName, string userName, string password, int port)
             : this(connectionString, hostName, userName, password, port)
         {
-            _rabbitMQModel = new RabbitMQModel(_model);
+            _rabbitMQModel = new RabbitMQModel(_connection, _model);
             _queueName = queueName ?? throw new ArgumentNullException(nameof(queueName));
 
             _model.QueueDeclarePassive(_queueName); // Throws exception if queue doesn't exist

src/Trigger/RabbitMQModel.cs

@@ -1,20 +1,27 @@
 // Copyright (c) .NET Foundation. All rights reserved.
 // Licensed under the MIT License. See License.txt in the project root for license information.
 
+using System;
 using System.Collections.Generic;
 using RabbitMQ.Client;
 
 namespace Microsoft.Azure.WebJobs.Extensions.RabbitMQ
 {
-    public class RabbitMQModel : IRabbitMQModel
+    public class RabbitMQModel : IRabbitMQModel, IDisposable
     {
         private readonly IModel _model;
+        private readonly IConnection _connection;
 
-        public RabbitMQModel(IModel model)
+        private bool _disposed = false;
+
+        public RabbitMQModel(IConnection connection, IModel model)
         {
             _model = model;
+            _connection = connection;
         }
 
+        ~RabbitMQModel() => Dispose(false);
+
         public IModel Model => _model;
 
         public IBasicPublishBatch CreateBasicPublishBatch()
@@ -74,7 +81,25 @@ public void ExchangeDeclare(string exchange, string exchangeType)
 
         public void Close()
         {
+            _disposed = true;
             _model.Close();
+            _connection.Close();
+        }
+
+        public void Dispose()
+        {
+            Dispose(true);
+            GC.SuppressFinalize(this);
+        }
+
+        protected virtual void Dispose(bool disposing)
+        {
+            if (_disposed)
+            {
+                return;
+            }
+
+            Close();
         }
     }
 }