@@ -168,12 +168,9 @@ local_destination_forward_headers_amqp10(Config) ->
168
168
Msg = # amqp_msg {props = # 'P_basic' {}},
169
169
publish (Chan , Msg , ? EXCHANGE , ? TO_SHOVEL ),
170
170
171
- [NodeA ] = rabbit_ct_broker_helpers :get_node_configs (Config , nodename ),
172
- Node = atom_to_binary (NodeA ),
173
-
174
171
receive
175
172
{amqp10_msg , Receiver , InMsg } ->
176
- ? assertMatch (#{<<" x-opt-shovelled-by" >> := Node ,
173
+ ? assertMatch (#{<<" x-opt-shovelled-by" >> := _ ,
177
174
<<" x-opt-shovel-type" >> := <<" static" >>,
178
175
<<" x-opt-shovel-name" >> := <<" test_shovel" >>},
179
176
amqp10_msg :message_annotations (InMsg ))
@@ -196,16 +193,12 @@ local_destination_forward_headers_amqp091(Config) ->
196
193
Msg = # amqp_msg {props = # 'P_basic' {}},
197
194
publish (Chan , Msg , ? EXCHANGE , ? TO_SHOVEL ),
198
195
199
- [NodeA ] = rabbit_ct_broker_helpers :get_node_configs (Config , nodename ),
200
- Node = atom_to_binary (NodeA ),
201
- ExpectedHeaders = lists :sort (
202
- [{<<" x-opt-shovelled-by" >>, longstr , Node },
203
- {<<" x-opt-shovel-type" >>, longstr , <<" static" >>},
204
- {<<" x-opt-shovel-name" >>, longstr , <<" test_shovel" >>}]),
205
196
receive
206
197
{# 'basic.deliver' {consumer_tag = CTag },
207
198
# amqp_msg {props = # 'P_basic' {headers = Headers }}} ->
208
- ? assertMatch (ExpectedHeaders ,
199
+ ? assertMatch ([{<<" x-opt-shovel-name" >>, longstr , <<" test_shovel" >>},
200
+ {<<" x-opt-shovel-type" >>, longstr , <<" static" >>},
201
+ {<<" x-opt-shovelled-by" >>, longstr , _ }],
209
202
lists :sort (Headers ))
210
203
after ? TIMEOUT -> throw (timeout_waiting_for_deliver1 )
211
204
end ,
0 commit comments