Fix (#58)

* Fix

Signed-off-by: Gabriele Santomaggio <[email protected]>

* formatting

---------

Signed-off-by: Gabriele Santomaggio <[email protected]>
Co-authored-by: Daniele <[email protected]>

Author: Gsantomaggio

poetry.lock

@@ -9,7 +9,6 @@ readme = "README.md"
 [tool.poetry.dependencies]
 python = "^3.9"
 python-qpid-proton = "^0.39.0"
-jwt = "^1.3.1"
 pyjwt = "^2.10.1"
 
 [tool.poetry.group.dev.dependencies]

pyproject.toml

@@ -139,7 +139,7 @@ def _create_connection(self) -> None:
         mechs = None
 
         if self._oauth2_options is not None:
-            user = ""
+            user = "no"
             password = self._oauth2_options.token
             mechs = "PLAIN"
             print("password, mechs: " + user + " " + password)

rabbitmq_amqp_python_client/connection.py

@@ -467,7 +467,8 @@ def __init__(
                 )
 
             except ConnectionException:
-                self.conn.close()
+                if self.conn is not None:
+                    self.conn.close()
                 if attempt == len(urls):
                     raise
                 continue

rabbitmq_amqp_python_client/qpid/proton/_utils.py

@@ -46,11 +46,11 @@ def environment_auth(pytestconfig):
         uri="amqp://localhost:5672",
         oauth2_options=OAuth2Options(token=token_string),
     )
-    try:
-        yield environment
+    # try:
+    return environment
 
-    finally:
-        environment.close()
+    # finally:
+    #     environment.close()
 
 
 @pytest.fixture()