format

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

Author: Gsantomaggio

examples/getting_started/getting_started.py

@@ -24,7 +24,7 @@ def __init__(self):
         self._count = 0
 
     def on_amqp_message(self, event: Event):
-        print("received message: {} ".format(''.join(map(chr, event.message.body))))
+        print("received message: {} ".format("".join(map(chr, event.message.body))))
 
         # accepting
         self.delivery_context.accept(event)
@@ -122,7 +122,9 @@ def main() -> None:
     # publish 10 messages
     for i in range(MESSAGES_TO_PUBLISH):
         print("publishing")
-        status = publisher.publish(Message(body=str.encode("test message {} ".format(i))))
+        status = publisher.publish(
+            Message(body=str.encode("test message {} ".format(i)))
+        )
         if status.remote_state == OutcomeState.ACCEPTED:
             print("message accepted")
         elif status.remote_state == OutcomeState.RELEASED:

rabbitmq_amqp_python_client/qpid/proton/_exceptions.py

@@ -58,6 +58,7 @@ class MessageException(ProtonException):
 
     pass
 
+
 class ArgumentOutOfRangeException(MessageException):
     """
     An exception class raised when an argument is out of range.

rabbitmq_amqp_python_client/qpid/proton/_message.py

@@ -109,13 +109,7 @@ class Message(object):
     DEFAULT_PRIORITY = PN_DEFAULT_PRIORITY
     """ Default AMQP message priority"""
 
-    def __init__(
-            self,
-            body: Union[
-                bytes, dict, None
-            ] = None,
-            **kwargs
-    ) -> None:
+    def __init__(self, body: Union[bytes, dict, None] = None, **kwargs) -> None:
         # validate the types
 
         if not isinstance(body, (bytes, dict, type(None))):
@@ -513,7 +507,7 @@ def instructions(self) -> Optional[AnnotationDict]:
 
     @instructions.setter
     def instructions(
-            self, instructions: Optional[Dict[Union[str, int], "PythonAMQPData"]]
+        self, instructions: Optional[Dict[Union[str, int], "PythonAMQPData"]]
     ) -> None:
         if isinstance(instructions, dict):
             self.instruction_dict = AnnotationDict(instructions, raise_on_error=False)
@@ -536,7 +530,7 @@ def annotations(self) -> Optional[AnnotationDict]:
 
     @annotations.setter
     def annotations(
-            self, annotations: Optional[Dict[Union[str, int], "PythonAMQPData"]]
+        self, annotations: Optional[Dict[Union[str, int], "PythonAMQPData"]]
     ) -> None:
         if isinstance(annotations, dict):
             self.annotation_dict = AnnotationDict(annotations, raise_on_error=False)
@@ -603,8 +597,7 @@ def send(self, sender: "Sender", tag: Optional[str] = None) -> "Delivery":
         return dlv
 
     @overload
-    def recv(self, link: "Sender") -> None:
-        ...
+    def recv(self, link: "Sender") -> None: ...
 
     def recv(self, link: "Receiver") -> Optional["Delivery"]:
         """
@@ -635,24 +628,24 @@ def recv(self, link: "Receiver") -> Optional["Delivery"]:
     def __repr__(self) -> str:
         props = []
         for attr in (
-                "inferred",
-                "address",
-                "reply_to",
-                "durable",
-                "ttl",
-                "priority",
-                "first_acquirer",
-                "delivery_count",
-                "id",
-                "correlation_id",
-                "user_id",
-                "group_id",
-                "group_sequence",
-                "reply_to_group_id",
-                "instructions",
-                "annotations",
-                "properties",
-                "body",
+            "inferred",
+            "address",
+            "reply_to",
+            "durable",
+            "ttl",
+            "priority",
+            "first_acquirer",
+            "delivery_count",
+            "id",
+            "correlation_id",
+            "user_id",
+            "group_id",
+            "group_sequence",
+            "reply_to_group_id",
+            "instructions",
+            "annotations",
+            "properties",
+            "body",
         ):
             value = getattr(self, attr)
             if value:

rabbitmq_amqp_python_client/qpid/proton/_utils.py

@@ -176,7 +176,6 @@ def send(
         :return: Delivery object for this message.
         """
 
-
         delivery = self.link.send(msg)
         self.connection.wait(
             lambda: _is_settled(delivery),