We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c7027df commit c15a1a4Copy full SHA for c15a1a4
rabbitmq_amqp_python_client/amqp_connection.py
@@ -0,0 +1,19 @@
1
+import abc
2
+from proton.utils import BlockingConnection
3
+
4
+class Connection(abc.ABC):
5
6
+ def __self__(self, addr: str):
7
+ self._addr = addr
8
9
+ def dial(self, addr: str) -> BlockingConnection:
10
+ return BlockingConnection(self._addr)
11
12
13
+ # closes the connection to the AMQP 1.0 server.
14
+ def close(self) -> None:
15
+ pass
16
17
+ # returns the current status of the connection.
18
+ def status(self) -> int:
19
0 commit comments