adding user-defined exception

Author: DanielePalaia

examples/getting_started/main.py

@@ -23,7 +23,7 @@ def main() -> None:
         QueueSpecification(name=queue_name, queue_type=QueueType.quorum, arguments={})
     )
 
-    binding_exchange_queue_path = management.bind(
+    management.bind(
         BindingSpecification(
             source_exchange=exchange_name,
             destination_queue=queue_name,
@@ -49,7 +49,7 @@ def main() -> None:
     publisher.close()
     """
 
-    management.unbind(binding_exchange_queue_path)
+    # management.unbind(binding_exchange_queue_path)
 
     """
     management.purge_queue(queue_info.name)

rabbitmq_amqp_python_client/exceptions.py

@@ -0,0 +1,8 @@
+class ValidationCodeException(Exception):
+    # Constructor or Initializer
+    def __init__(self, msg: str):
+        self.msg = msg
+
+    # __str__ is to print() the value
+    def __str__(self) -> str:
+        return repr(self.msg)

rabbitmq_amqp_python_client/management.py

@@ -21,6 +21,7 @@
     ExchangeSpecification,
     QueueSpecification,
 )
+from .exceptions import ValidationCodeException
 from .options import ReceiverOption, SenderOption
 
 
@@ -131,8 +132,8 @@ def declare_queue(
             path,
             CommonValues.command_put.value,
             [
+                CommonValues.response_code_200.value,
                 CommonValues.response_code_201.value,
-                CommonValues.response_code_204.value,
                 CommonValues.response_code_409.value,
             ],
         )
@@ -171,13 +172,15 @@ def _validate_reponse_code(
         print("response_code received: " + str(response_code))
         if response_code == CommonValues.response_code_409.value:
             # TODO replace with a new defined Exception
-            raise Exception("ErrPreconditionFailed")
+            raise ValidationCodeException("ErrPreconditionFailed")
 
         for code in expected_response_codes:
             if code == response_code:
                 return None
 
-        raise Exception("wrong response code received")
+        raise ValidationCodeException(
+            "wrong response code received: " + str(response_code)
+        )
 
     # TODO
     def bind(self, bind_specification: BindingSpecification) -> str: