adding publisher basic test

Author: DanielePalaia

examples/getting_started/main.py

@@ -1,9 +1,8 @@
-from proton import Message
-
 from rabbitmq_amqp_python_client import (
     BindingSpecification,
     Connection,
     ExchangeSpecification,
+    Message,
     QueueSpecification,
     QueueType,
     exchange_address,

rabbitmq_amqp_python_client/__init__.py

@@ -1,5 +1,7 @@
 from importlib import metadata
 
+from proton import Message
+
 from .address_helper import exchange_address
 from .common import QueueType
 from .connection import Connection
@@ -27,4 +29,5 @@
     "QueueType",
     "Publisher",
     "exchange_address",
+    "Message",
 ]

tests/test_publisher.py

@@ -0,0 +1,32 @@
+from rabbitmq_amqp_python_client import (
+    Connection,
+    Message,
+    QueueSpecification,
+    QueueType,
+)
+
+
+def test_bind_exchange_to_queue() -> None:
+    connection = Connection("amqp://guest:guest@localhost:5672/")
+    connection.dial()
+
+    queue_name = "test-queue"
+    management = connection.management()
+
+    management.declare_queue(
+        QueueSpecification(name=queue_name, queue_type=QueueType.quorum, arguments={})
+    )
+
+    raised = False
+
+    try:
+        publisher = connection.publisher("/queues/" + queue_name)
+        publisher.publish(Message(body="test"))
+    except Exception:
+        raised = True
+
+    assert raised is False
+
+    publisher.close()
+    # Still not working
+    # management.delete_queue(queue_name)