@@ -67,13 +67,37 @@ end_per_testcase(Testcase, Config) ->
6767declare_exchanges (Config ) ->
6868 Channel = rabbit_ct_client_helpers :open_channel (Config ),
6969
70- DeclareInt = # 'exchange.declare' {exchange = <<" test_exchange_integers" >>,
71- type = <<" x-message-deduplication" >>,
72- auto_delete = true ,
73- arguments = [{<<" x-cache-size" >>, long , 10 },
74- {<<" x-cache-ttl" >>, long , 1000 },
75- {<<" x-cache-persistence" >>, longstr , " memory" }]},
76- # 'exchange.declare_ok' {} = amqp_channel :call (Channel , DeclareInt ),
70+ DeclareShort = # 'exchange.declare' {exchange = <<" test_exchange_short" >>,
71+ type = <<" x-message-deduplication" >>,
72+ auto_delete = true ,
73+ arguments = [{<<" x-cache-size" >>, short , 10 },
74+ {<<" x-cache-ttl" >>, short , 1000 },
75+ {<<" x-cache-persistence" >>, longstr , " memory" }]},
76+ # 'exchange.declare_ok' {} = amqp_channel :call (Channel , DeclareShort ),
77+
78+ DeclareLong = # 'exchange.declare' {exchange = <<" test_exchange_long" >>,
79+ type = <<" x-message-deduplication" >>,
80+ auto_delete = true ,
81+ arguments = [{<<" x-cache-size" >>, long , 10 },
82+ {<<" x-cache-ttl" >>, long , 1000 },
83+ {<<" x-cache-persistence" >>, longstr , " memory" }]},
84+ # 'exchange.declare_ok' {} = amqp_channel :call (Channel , DeclareLong ),
85+
86+ DeclareSigned = # 'exchange.declare' {exchange = <<" test_exchange_signed" >>,
87+ type = <<" x-message-deduplication" >>,
88+ auto_delete = true ,
89+ arguments = [{<<" x-cache-size" >>, signedint , 10 },
90+ {<<" x-cache-ttl" >>, signedint , 1000 },
91+ {<<" x-cache-persistence" >>, longstr , " memory" }]},
92+ # 'exchange.declare_ok' {} = amqp_channel :call (Channel , DeclareSigned ),
93+
94+ DeclareUnsigned = # 'exchange.declare' {exchange = <<" test_exchange_unsigned" >>,
95+ type = <<" x-message-deduplication" >>,
96+ auto_delete = true ,
97+ arguments = [{<<" x-cache-size" >>, unsignedint , 10 },
98+ {<<" x-cache-ttl" >>, unsignedint , 1000 },
99+ {<<" x-cache-persistence" >>, longstr , " memory" }]},
100+ # 'exchange.declare_ok' {} = amqp_channel :call (Channel , DeclareUnsigned ),
77101
78102 DeclareStr = # 'exchange.declare' {exchange = <<" test_exchange_strings" >>,
79103 type = <<" x-message-deduplication" >>,
0 commit comments