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 22
33from rabbitmq_amqp_python_client import (
44 ClassicQueueSpecification ,
5+ ExchangeCustomSpecification ,
56 ExchangeSpecification ,
67 ExchangeToExchangeBindingSpecification ,
78 ExchangeToQueueBindingSpecification ,
@@ -42,6 +43,26 @@ def test_declare_delete_exchange_headers(management: Management) -> None:
4243 management .delete_exchange (exchange_name )
4344
4445
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+
4566def test_declare_delete_exchange_with_args (management : Management ) -> None :
4667
4768 exchange_name = "test-exchange-with-args"
You can’t perform that action at this time.
0 commit comments