Log when failing to close connection

primait · May 21, 2024 · e9ea055 · e9ea055
1 parent 94b9482
commit e9ea055
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/lib/amqp/gen/connection_manager.ex b/lib/amqp/gen/connection_manager.ex
@@ -64,7 +64,10 @@ defmodule Amqpx.Gen.ConnectionManager do
 
   def terminate(_, %__MODULE__{connection: connection}) do
     if Process.alive?(connection.pid) do
-      Connection.close(connection)
+      case Connection.close(connection) do
+        :ok -> :ok
+        error -> Logger.warning("Error while closing connection", error: inspect(error))
+      end
     end
   end