File tree Expand file tree Collapse file tree 1 file changed +21
-0
lines changed Expand file tree Collapse file tree 1 file changed +21
-0
lines changed Original file line number Diff line number Diff line change 2
2
3
3
from rabbitmq_amqp_python_client import (
4
4
ClassicQueueSpecification ,
5
+ ExchangeCustomSpecification ,
5
6
ExchangeSpecification ,
6
7
ExchangeToExchangeBindingSpecification ,
7
8
ExchangeToQueueBindingSpecification ,
@@ -42,6 +43,26 @@ def test_declare_delete_exchange_headers(management: Management) -> None:
42
43
management .delete_exchange (exchange_name )
43
44
44
45
46
+ def test_declare_delete_exchange_custom (management : Management ) -> None :
47
+
48
+ exchange_name = "test-exchange"
49
+
50
+ exchange_arguments = {}
51
+ exchange_arguments ["x-delayed-type" ] = "direct"
52
+
53
+ exchange_info = management .declare_exchange (
54
+ ExchangeCustomSpecification (
55
+ name = exchange_name ,
56
+ exchange_type = "x-local-random" ,
57
+ arguments = exchange_arguments ,
58
+ )
59
+ )
60
+
61
+ assert exchange_info .name == exchange_name
62
+
63
+ management .delete_exchange (exchange_name )
64
+
65
+
45
66
def test_declare_delete_exchange_with_args (management : Management ) -> None :
46
67
47
68
exchange_name = "test-exchange-with-args"
You can’t perform that action at this time.
0 commit comments