@@ -21,33 +21,35 @@ def main() -> None:
21
21
22
22
management .declare_exchange (ExchangeSpecification (name = exchange_name , arguments = {}))
23
23
24
- management .declare_queue (
24
+ binding_exchange_queue_path = management .declare_queue (
25
25
QueueSpecification (name = queue_name , queue_type = QueueType .quorum , arguments = {})
26
26
)
27
27
28
- management .bind (
29
- BindingSpecification (
30
- source_exchange = exchange_name ,
31
- destination_queue = queue_name ,
32
- binding_key = routing_key ,
33
- )
34
- )
35
28
36
- addr = exchange_address (exchange_name , routing_key )
29
+ #management.bind(
30
+ # BindingSpecification(
31
+ # source_exchange=exchange_name,
32
+ # destination_queue=queue_name,
33
+ # binding_key=routing_key,
34
+ # )
35
+ #)
36
+
37
+ #addr = exchange_address(exchange_name, routing_key)
37
38
38
- publisher = connection .publisher (addr )
39
+ # publisher = connection.publisher(addr)
39
40
40
- publisher .publish (Message (body = "test" ))
41
+ # publisher.publish(Message(body="test"))
41
42
42
- publisher .close ()
43
+ # publisher.close()
43
44
44
- # management.unbind(binding_exchange_queue_path)
45
+ #management.unbind(binding_exchange_queue_path)
45
46
46
47
# management.purge_queue(queue_info.name)
47
48
48
- # management.delete_queue(queue_name)
49
+ management .delete_queue (queue_name )
50
+
51
+ management .delete_exchange (exchange_name )
49
52
50
- # management.delete_exchange(exchange_name)
51
53
52
54
management .close ()
53
55
0 commit comments