making exchange arguments optional

Author: DanielePalaia

examples/getting_started/basic_example.py

@@ -93,7 +93,7 @@ def main() -> None:
     management = connection.management()
 
     print("declaring exchange and queue")
-    management.declare_exchange(ExchangeSpecification(name=exchange_name, arguments={}))
+    management.declare_exchange(ExchangeSpecification(name=exchange_name))
 
     management.declare_queue(
         QuorumQueueSpecification(name=queue_name)

examples/getting_started/reconnection_example.py

@@ -150,7 +150,7 @@ def main() -> None:
 
     print("declaring exchange and queue")
     connection_configuration.management.declare_exchange(
-        ExchangeSpecification(name=exchange_name, arguments={})
+        ExchangeSpecification(name=exchange_name)
     )
 
     connection_configuration.management.declare_queue(

examples/getting_started/tls_example.py

@@ -93,7 +93,7 @@ def main() -> None:
     management = connection.management()
 
     print("declaring exchange and queue")
-    management.declare_exchange(ExchangeSpecification(name=exchange_name, arguments={}))
+    management.declare_exchange(ExchangeSpecification(name=exchange_name))
 
     management.declare_queue(
         QuorumQueueSpecification(name=queue_name)

rabbitmq_amqp_python_client/entities.py

@@ -1,4 +1,4 @@
-from dataclasses import dataclass
+from dataclasses import dataclass, field
 from enum import Enum
 from typing import Any, Dict, Optional, Union
 
@@ -13,7 +13,7 @@
 @dataclass
 class ExchangeSpecification:
     name: str
-    arguments: dict[str, str]
+    arguments: dict[str, str] = field(default_factory=dict)
     exchange_type: ExchangeType = ExchangeType.direct
     is_auto_delete: bool = False
     is_internal: bool = False
@@ -24,7 +24,7 @@ class ExchangeSpecification:
 class QueueInfo:
     name: str
     arguments: dict[str, Any]
-    queue_type: QueueType = QueueType.quorum
+    queue_type: QueueType = QueueType.classic
     is_exclusive: Optional[bool] = None
     is_auto_delete: bool = False
     is_durable: bool = True

tests/test_management.py

@@ -17,7 +17,7 @@ def test_declare_delete_exchange(management: Management) -> None:
     exchange_name = "test-exchange"
 
     exchange_info = management.declare_exchange(
-        ExchangeSpecification(name=exchange_name, arguments={})
+        ExchangeSpecification(name=exchange_name)
     )
 
     assert exchange_info.name == exchange_name
@@ -43,7 +43,7 @@ def test_bind_exchange_to_queue(management: Management) -> None:
     queue_name = "test-bind-exchange-to-queue-queue"
     routing_key = "routing-key"
 
-    management.declare_exchange(ExchangeSpecification(name=exchange_name, arguments={}))
+    management.declare_exchange(ExchangeSpecification(name=exchange_name))
 
     management.declare_queue(QuorumQueueSpecification(name=queue_name))
 

tests/test_publisher.py

@@ -97,7 +97,7 @@ def test_publish_exchange(connection: Connection) -> None:
     management = connection.management()
     routing_key = "routing-key"
 
-    management.declare_exchange(ExchangeSpecification(name=exchange_name, arguments={}))
+    management.declare_exchange(ExchangeSpecification(name=exchange_name))
 
     management.declare_queue(QuorumQueueSpecification(name=queue_name))