formatting

Author: Gsantomaggio

examples/tls/tls_example.py

@@ -36,7 +36,7 @@ def __init__(self):
         self._count = 0
 
     def on_message(self, event: Event):
-        print("received message: " + str(event.message.body))
+        print("received message: " + Converter.bytes_to_string(event.message.body))
 
         # accepting
         self.delivery_context.accept(event)

rabbitmq_amqp_python_client/converter.py

@@ -86,12 +86,11 @@
 from ._endpoints import Link
 from ._exceptions import (
     EXCEPTIONS,
-    ArgumentOutOfRangeException,
     MessageException,
 )
 
 if TYPE_CHECKING:
-    from proton._data import Described, PythonAMQPData
+    from proton._data import PythonAMQPData
     from proton._delivery import Delivery
     from proton._endpoints import Receiver, Sender
 

rabbitmq_amqp_python_client/qpid/proton/_message.py

@@ -7,3 +7,45 @@ def validate_annotations(annotations: []) -> bool:  # type: ignore
             validated = False
             return validated
     return validated
+
+
+def string_to_bytes(body: str) -> bytes:
+    """
+    Convert a string to the body of a message.
+
+    Args:
+        body: The string to convert
+
+    Returns:
+        bytes: The byte representation of the string
+    """
+    return str.encode(body)
+
+
+class Converter:
+
+    @staticmethod
+    def bytes_to_string(body: bytes) -> str:
+        """
+        Convert the body of a message to a string.
+
+        Args:
+            body: The body of the message
+
+        Returns:
+            str: The string representation of the body
+        """
+        return "".join(map(chr, body))
+
+    @staticmethod
+    def string_to_bytes(body: str) -> bytes:
+        """
+        Convert a string to the body of a message.
+
+        Args:
+            body: The string to convert
+
+        Returns:
+            bytes: The byte representation of the string
+        """
+        return str.encode(body)

rabbitmq_amqp_python_client/utils.py

@@ -131,7 +131,7 @@ def test_publish_to_invalid_destination(connection: Connection) -> None:
     publisher = None
     try:
         publisher = connection.publisher("/invalid-destination/" + queue_name)
-        publisher.publish(Message(body=string_to_bytes("test")))
+        publisher.publish(Message(body=Converter.string_to_bytes("test")))
     except ArgumentOutOfRangeException:
         raised = True
     except Exception: