@@ -168,12 +168,9 @@ local_destination_forward_headers_amqp10(Config) ->
168168 Msg = # amqp_msg {props = # 'P_basic' {}},
169169 publish (Chan , Msg , ? EXCHANGE , ? TO_SHOVEL ),
170170
171- [NodeA ] = rabbit_ct_broker_helpers :get_node_configs (Config , nodename ),
172- Node = atom_to_binary (NodeA ),
173-
174171 receive
175172 {amqp10_msg , Receiver , InMsg } ->
176- ? assertMatch (#{<<" x-opt-shovelled-by" >> := Node ,
173+ ? assertMatch (#{<<" x-opt-shovelled-by" >> := _ ,
177174 <<" x-opt-shovel-type" >> := <<" static" >>,
178175 <<" x-opt-shovel-name" >> := <<" test_shovel" >>},
179176 amqp10_msg :message_annotations (InMsg ))
@@ -196,16 +193,12 @@ local_destination_forward_headers_amqp091(Config) ->
196193 Msg = # amqp_msg {props = # 'P_basic' {}},
197194 publish (Chan , Msg , ? EXCHANGE , ? TO_SHOVEL ),
198195
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" >>}]),
205196 receive
206197 {# 'basic.deliver' {consumer_tag = CTag },
207198 # 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 , _ }],
209202 lists :sort (Headers ))
210203 after ? TIMEOUT -> throw (timeout_waiting_for_deliver1 )
211204 end ,
0 commit comments