WIP

Author: DanielePalaia

examples/getting_started/Makefile

@@ -0,0 +1,11 @@
+.PHONY: main all
+
+main:
+	@echo "running excample"
+	venv/bin/python3 ./main.py
+
+init-python:
+	@echo "init python venv"
+	rm -rf venv
+	python3 -m venv venv
+	venv/bin/pip install -r requirements.txt

examples/getting_started/main.py

@@ -0,0 +1,74 @@
+# from proton import Message
+
+from rabbitmq_amqp_python_client import (
+    Connection,
+    ExchangeSpecification,
+)
+
+
+def main():
+    exchange_name = "example-exchange"
+    connection = Connection("amqp://guest:guest@localhost:5672/")
+
+    connection.dial()
+
+    management = connection.management()
+
+    exchange_info = management.declare_exchange(
+        ExchangeSpecification(name=exchange_name, arguments={})
+    )
+
+    """ 
+    queue_info = management.declare_queue(QueueSpecification{
+		name:      queue_name,       
+		queue_type: QueueType{type: Quorum},
+	})
+    """
+
+    """
+    #management.bind(BindingSpecification{
+		source_exchange:   exchange_name,
+		destination_queue: queue_name,
+		binding_key:       routing_key,
+	})
+    """
+
+    """
+    addr = exchange_address(exchange_name, routing_key)
+    """
+
+    """
+    publisher = connection.publisher(addr, "getting-started-publisher")
+    """
+
+    """
+    message = Message(
+        body='test',
+        address='/queues/getting-started-exchangemessage',
+    )
+
+    publisher.Publish(message)
+    publisher.close()
+    """
+
+    """
+    management.unbind(binding_path)
+    """
+
+    """
+    management.purge_queue(queue_info.name)
+    """
+
+    """
+    management.delete_queue(queue_info.name)
+    """
+
+    """
+    management.delete_exchange(exchange_info.name)
+    """
+
+    # connection.close()
+
+
+if __name__ == "__main__":
+    main()

examples/getting_started/requirements.txt

@@ -0,0 +1 @@
+/Users/dpalaia/projects/rabbitmq-amqp-python-client

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "rabbitmq-amqp-python-client"
-version = "0.1.0"
+version = "0.0.1"
 description = "Python RabbitMQ client for AMQP 1.0 protocol"
 authors = ["RabbitMQ team"]
 license = "Apache-2.0 license"

rabbitmq_amqp_python_client/__init__.py

@@ -0,0 +1,18 @@
+from importlib import metadata
+
+from .connection import Connection
+from .entities import ExchangeSpecification
+
+try:
+    __version__ = metadata.version(__package__)
+    __license__ = metadata.metadata(__package__)["license"]
+except metadata.PackageNotFoundError:
+    __version__ = "dev"
+    __license__ = None
+
+del metadata
+
+__all__ = [
+    "Connection",
+    "ExchangeSpecification",
+]

rabbitmq_amqp_python_client/address_helper.py

@@ -0,0 +1,4 @@
+def exchange_address(name: str) -> str:
+    path = "/exchanges/" + name
+
+    return path

rabbitmq_amqp_python_client/amqp_connection.py

@@ -0,0 +1,26 @@
+import enum
+
+
+class CommonValues(enum.Enum):
+    response_code_200 = 200
+    response_code_201 = 201
+    response_code_204 = 204
+    response_code_404 = 404
+    response_code_409 = 409
+    command_put = "PUT"
+    command_get = "GET"
+    command_post = "POST"
+    command_delete = "DELETE"
+    command_reply_to = "$me"
+    management_node_address = "/management"
+    link_pair_name = "management-link-pair"
+    exchanges = "exchanges"
+    key = "key"
+    queue = "queues"
+    bindings = "bindings"
+
+
+class ExchangeTypes(enum.Enum):
+    direct = "direct"
+    topic = "topic"
+    fanout = "fanout"

rabbitmq_amqp_python_client/common.py

@@ -0,0 +1,33 @@
+from proton._data import PropertyDict, symbol  # noqa: E402
+from proton._endpoints import Link  # noqa: E402
+from proton.reactor import LinkOption  # noqa: E402
+
+
+class SenderOption(LinkOption):
+    def __init__(self, addr: str):
+        self._addr = addr
+
+    def apply(self, link: Link) -> None:
+        link.source.address = self._addr
+        link.snd_settle_mode = Link.SND_SETTLED
+        link.rcv_settle_mode = Link.RCV_FIRST
+        link.properties = PropertyDict({symbol("paired"): True})
+        link.source.dynamic = False
+
+    def test(self, link: Link) -> bool:
+        return bool(link.is_sender)
+
+
+class ReceiverOption(LinkOption):
+    def __init__(self, addr: str):
+        self._addr = addr
+
+    def apply(self, link: Link) -> None:
+        link.target.address = self._addr
+        link.snd_settle_mode = Link.SND_SETTLED
+        link.rcv_settle_mode = Link.RCV_FIRST
+        link.properties = PropertyDict({symbol("paired"): True})
+        link.source.dynamic = False
+
+    def test(self, link: Link) -> bool:
+        return bool(link.is_receiver)

rabbitmq_amqp_python_client/configuration_options.py

@@ -0,0 +1,37 @@
+from proton.utils import (
+    BlockingConnection,
+    BlockingReceiver,
+    BlockingSender,
+)
+
+from .configuration_options import (
+    ReceiverOption,
+    SenderOption,
+)
+from .management import Management
+
+
+class Connection:
+    def __init__(self, addr: str):
+        self._addr: str = addr
+        self._conn: BlockingConnection
+        self._management: Management
+
+    def dial(self) -> None:
+        self._conn = BlockingConnection(self._addr)
+        self._open()
+
+    def _open(self) -> None:
+        self._management = Management(self._conn)
+        self._management.open()
+
+    def management(self) -> Management:
+        return self._management
+
+    # closes the connection to the AMQP 1.0 server.
+    def close(self) -> None:
+        self._conn.close()
+
+    # TODO: returns the current status of the connection.
+    # def status(self) -> int:
+    #    pass