Implementing Connection, Management and Publisher modules (#10)

* connection layer implementation

* WIP

* implementing Declare Exchange/Queue

* test for gabriele

* body encodiding

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

* adding basic tests

* implementing bind

* adding user-defined exception

* Adding debugging info

* publisher implementation

* adding publisher basic test

* improve help_address utility functions

* modify example

* integrate qpid-proton lib

* implementing purge operation

* improving url helper

* cleaning up qpid unecessary folders and files

* some improvements

* implementing queue_info

* fixing queue arguments management

* better management of arguments

* improved arguments management during declare_queue

* adding purge test

* adding fixtures in tests

* adding a publisher test

* removing useless queue_type parameter

* removing receiver from publisher

---------

Signed-off-by: Gabriele Santomaggio <[email protected]>
Co-authored-by: DanielePalaia <daniele985@@gmail.com>
Co-authored-by: Gabriele Santomaggio <[email protected]>

Author: 3 people

examples/getting_started/main.py

@@ -1,3 +1,5 @@
+# type: ignore
+
 from rabbitmq_amqp_python_client import (
     BindingSpecification,
     Connection,
@@ -84,11 +86,9 @@ def main() -> None:
     print("unbind")
     management.unbind(bind_name)
 
-
-
     consumer.close()
     print("delete queue")
-    #management.delete_queue(queue_name)
+    # management.delete_queue(queue_name)
 
     print("delete exchange")
     management.delete_exchange(exchange_name)

rabbitmq_amqp_python_client/qpid/proton/_utils.py

@@ -273,8 +273,6 @@ def __init__(
         if credit:
             receiver.flow(credit)
 
-        if fetcher is None:
-            print("fetcher is none")
         self.fetcher = fetcher
         self.container = connection.container
 

tests/test_publisher.py

@@ -72,6 +72,8 @@ def test_publish_exchange(connection: Connection) -> None:
 
 
 def test_publish_purge(connection: Connection) -> None:
+    connection = Connection("amqp://guest:guest@localhost:5672/")
+    connection.dial()
 
     queue_name = "test-queue"
     management = connection.management()
@@ -82,17 +84,17 @@ def test_publish_purge(connection: Connection) -> None:
 
     try:
         publisher = connection.publisher("/queues/" + queue_name)
-        for i in range(100):
+        for i in range(20):
             publisher.publish(Message(body="test"))
     except Exception:
         raised = True
 
-    time.sleep(5)
+    time.sleep(4)
 
     message_purged = management.purge_queue(queue_name)
 
     assert raised is False
-    assert message_purged == 100
+    assert message_purged == 20
 
     publisher.close()