Skip to content

Commit 67a7f59

Browse files
michaelklishinmichaelklishin
committed
Squash nextest run warnings
1 parent 9f817c2 commit 67a7f59

File tree

4 files changed

+63
-68
lines changed

4 files changed

+63
-68
lines changed

‎.config/nextest.toml

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -4,11 +4,6 @@ default-filter = "all()"
44
retries = 2
55
test-threads = "num-cpus"
66

7-
filter = 'package(rabbitmqadmin)'
8-
# an overridable default
9-
priority = 0
10-
test-group = 'parallel_safe'
11-
127
status-level = "retry"
138
final-status-level = "pass"
149
failure-output = "immediate"

‎tests/exchange_federation_tests.rs

Lines changed: 22 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -40,9 +40,9 @@ fn test_federation_upstream_declaration_for_exchange_federation_case0()
4040
"federation",
4141
"declare_upstream_for_exchanges",
4242
"--name",
43-
&upstream.name,
43+
upstream.name,
4444
"--uri",
45-
&upstream.uri,
45+
upstream.uri,
4646
]);
4747

4848
delete_vhost(vh).expect("failed to delete a virtual host");
@@ -73,11 +73,11 @@ fn test_federation_upstream_declaration_for_exchange_federation_case1a()
7373
"federation",
7474
"declare_upstream_for_exchanges",
7575
"--name",
76-
&upstream.name,
76+
upstream.name,
7777
"--uri",
78-
&upstream.uri,
78+
upstream.uri,
7979
"--exchange-name",
80-
&x,
80+
x,
8181
"--queue-type",
8282
&xfp.queue_type.to_string(),
8383
]);
@@ -110,11 +110,11 @@ fn test_federation_upstream_declaration_for_exchange_federation_case1b()
110110
"federation",
111111
"declare_upstream",
112112
"--name",
113-
&upstream.name,
113+
upstream.name,
114114
"--uri",
115-
&upstream.uri,
115+
upstream.uri,
116116
"--exchange-name",
117-
&x,
117+
x,
118118
"--queue-type",
119119
&xfp.queue_type.to_string(),
120120
// queue federation
@@ -150,11 +150,11 @@ fn test_federation_upstream_declaration_for_exchange_federation_case2()
150150
"federation",
151151
"declare_upstream_for_exchanges",
152152
"--name",
153-
&upstream.name,
153+
upstream.name,
154154
"--uri",
155-
&upstream.uri,
155+
upstream.uri,
156156
"--exchange-name",
157-
&x,
157+
x,
158158
"--queue-type",
159159
&xfp.queue_type.to_string(),
160160
"--max-hops",
@@ -194,9 +194,9 @@ fn test_federation_upstream_declaration_for_exchange_federation_case3()
194194
"federation",
195195
"declare_upstream_for_exchanges",
196196
"--uri",
197-
&upstream.uri,
197+
upstream.uri,
198198
"--exchange-name",
199-
&x,
199+
x,
200200
"--queue-type",
201201
&xfp.queue_type.to_string(),
202202
])
@@ -233,9 +233,9 @@ fn test_federation_upstream_declaration_for_exchange_federation_case4()
233233
"federation",
234234
"declare_upstream_for_exchanges",
235235
"--name",
236-
&upstream.name,
236+
upstream.name,
237237
"--exchange-name",
238-
&x,
238+
x,
239239
"--queue-type",
240240
&xfp.queue_type.to_string(),
241241
"--max-hops",
@@ -274,11 +274,11 @@ fn test_federation_list_all_upstreams_with_exchange_federation()
274274
"federation",
275275
"declare_upstream_for_exchanges",
276276
"--name",
277-
&upstream.name,
277+
upstream.name,
278278
"--uri",
279-
&upstream.uri,
279+
upstream.uri,
280280
"--exchange-name",
281-
&x,
281+
x,
282282
"--queue-type",
283283
&xfp.queue_type.to_string(),
284284
"--max-hops",
@@ -323,11 +323,11 @@ fn test_federation_delete_an_upstream_with_exchange_federation_settings()
323323
"federation",
324324
"declare_upstream_for_exchanges",
325325
"--name",
326-
&upstream.name,
326+
upstream.name,
327327
"--uri",
328-
&upstream.uri,
328+
upstream.uri,
329329
"--exchange-name",
330-
&x,
330+
x,
331331
"--queue-type",
332332
&xfp.queue_type.to_string(),
333333
"--max-hops",
@@ -350,7 +350,7 @@ fn test_federation_delete_an_upstream_with_exchange_federation_settings()
350350
"federation",
351351
"delete_upstream",
352352
"--name",
353-
&upstream.name,
353+
upstream.name,
354354
]);
355355

356356
run_succeeds(["-V", vh, "federation", "list_all_upstreams"])

‎tests/queue_federation_tests.rs

Lines changed: 30 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -41,13 +41,13 @@ fn test_federation_upstream_declaration_for_queue_federation_case0()
4141
"federation",
4242
"declare_upstream_for_queues",
4343
"--name",
44-
&upstream.name,
44+
upstream.name,
4545
"--uri",
46-
&upstream.uri,
46+
upstream.uri,
4747
"--queue-name",
48-
&q,
48+
q,
4949
"--consumer-tag",
50-
&qfp.consumer_tag.unwrap(),
50+
qfp.consumer_tag.unwrap(),
5151
]);
5252

5353
delete_vhost(vh).expect("failed to delete a virtual host");
@@ -78,15 +78,15 @@ fn test_federation_upstream_declaration_for_queue_federation_case1a()
7878
"federation",
7979
"declare_upstream_for_queues",
8080
"--name",
81-
&upstream.name,
81+
upstream.name,
8282
"--uri",
83-
&upstream.uri,
83+
upstream.uri,
8484
"--ack-mode",
8585
"on-confirm",
8686
"--queue-name",
87-
&q,
87+
q,
8888
"--consumer-tag",
89-
&qfp.consumer_tag.unwrap(),
89+
qfp.consumer_tag.unwrap(),
9090
]);
9191

9292
delete_vhost(vh).expect("failed to delete a virtual host");
@@ -117,15 +117,15 @@ fn test_federation_upstream_declaration_for_queue_federation_case1b()
117117
"federation",
118118
"declare_upstream",
119119
"--name",
120-
&upstream.name,
120+
upstream.name,
121121
"--uri",
122-
&upstream.uri,
122+
upstream.uri,
123123
"--ack-mode",
124124
"on-confirm",
125125
"--queue-name",
126-
&q,
126+
q,
127127
"--consumer-tag",
128-
&qfp.consumer_tag.unwrap(),
128+
qfp.consumer_tag.unwrap(),
129129
// exchange federation
130130
"--queue-type",
131131
"quorum",
@@ -158,9 +158,9 @@ fn test_federation_upstream_declaration_for_queue_federation_case2()
158158
"federation",
159159
"declare_upstream_for_queues",
160160
"--name",
161-
&upstream.name,
161+
upstream.name,
162162
"--uri",
163-
&upstream.uri,
163+
upstream.uri,
164164
"--ack-mode",
165165
"on-publish",
166166
]);
@@ -193,7 +193,7 @@ fn test_federation_upstream_declaration_for_queue_federation_case3()
193193
"federation",
194194
"declare_upstream_for_queues",
195195
"--name",
196-
&upstream.name,
196+
upstream.name,
197197
])
198198
.stderr(predicate::str::contains(
199199
"required arguments were not provided",
@@ -227,7 +227,7 @@ fn test_federation_upstream_declaration_for_queue_federation_case4()
227227
"federation",
228228
"declare_upstream_for_queues",
229229
"--uri",
230-
&upstream.uri,
230+
upstream.uri,
231231
"--ack-mode",
232232
"on-publish",
233233
])
@@ -263,13 +263,13 @@ fn test_federation_list_all_upstreams_with_queue_federation()
263263
"federation",
264264
"declare_upstream_for_queues",
265265
"--name",
266-
&upstream.name,
266+
upstream.name,
267267
"--uri",
268-
&upstream.uri,
268+
upstream.uri,
269269
"--queue-name",
270-
&q,
270+
q,
271271
"--consumer-tag",
272-
&qfp.consumer_tag.unwrap(),
272+
qfp.consumer_tag.unwrap(),
273273
]);
274274

275275
run_succeeds(["-V", vh, "federation", "list_all_upstreams"])
@@ -306,13 +306,13 @@ fn test_federation_delete_an_upstream_with_queue_federation_settings()
306306
"federation",
307307
"declare_upstream_for_queues",
308308
"--name",
309-
&upstream.name,
309+
upstream.name,
310310
"--uri",
311-
&upstream.uri,
311+
upstream.uri,
312312
"--queue-name",
313-
&q,
313+
q,
314314
"--consumer-tag",
315-
&qfp.consumer_tag.unwrap(),
315+
qfp.consumer_tag.unwrap(),
316316
]);
317317

318318
run_succeeds(["federation", "list_all_upstreams"])
@@ -325,7 +325,7 @@ fn test_federation_delete_an_upstream_with_queue_federation_settings()
325325
"federation",
326326
"delete_upstream",
327327
"--name",
328-
&upstream.name,
328+
upstream.name,
329329
]);
330330

331331
run_succeeds(["federation", "list_all_upstreams"])
@@ -362,19 +362,19 @@ fn test_federation_list_all_links_with_queue_federation_settings()
362362
"federation",
363363
"declare_upstream",
364364
"--name",
365-
&upstream.name,
365+
upstream.name,
366366
"--uri",
367-
&upstream.uri,
367+
upstream.uri,
368368
"--ack-mode",
369369
"on-confirm",
370370
"--queue-name",
371-
&q,
371+
q,
372372
"--consumer-tag",
373-
&qfp.consumer_tag.unwrap(),
373+
qfp.consumer_tag.unwrap(),
374374
]);
375375

376376
run_succeeds([
377-
"-V", vh1, "declare", "queue", "--name", &q, "--type", "classic",
377+
"-V", vh1, "declare", "queue", "--name", q, "--type", "classic",
378378
]);
379379

380380
run_succeeds([

‎tests/shovel_tests.rs

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ fn test_shovel_declaration_without_source_uri() -> Result<(), Box<dyn std::error
3333
"shovels",
3434
"declare_amqp091",
3535
"--name",
36-
&name,
36+
name,
3737
"--destination-uri",
3838
&amqp_endpoint,
3939
"--source-queue",
@@ -66,7 +66,7 @@ fn test_shovel_declaration_without_destination_uri() -> Result<(), Box<dyn std::
6666
"shovels",
6767
"declare_amqp091",
6868
"--name",
69-
&name,
69+
name,
7070
"--source-uri",
7171
&amqp_endpoint,
7272
"--source-queue",
@@ -100,7 +100,7 @@ fn test_shovel_declaration_with_overlapping_destination_types()
100100
"shovels",
101101
"declare_amqp091",
102102
"--name",
103-
&name,
103+
name,
104104
"--source-uri",
105105
&amqp_endpoint,
106106
"--destination-uri",
@@ -114,9 +114,9 @@ fn test_shovel_declaration_with_overlapping_destination_types()
114114
])
115115
.stderr(predicate::str::contains("cannot be used with"));
116116

117-
run_succeeds(["-V", vh, "shovels", "delete", "--name", &name]);
117+
run_succeeds(["-V", vh, "shovels", "delete", "--name", name]);
118118

119-
run_succeeds(["-V", vh, "shovels", "delete", "--name", &name]);
119+
run_succeeds(["-V", vh, "shovels", "delete", "--name", name]);
120120

121121
delete_vhost(vh).expect("failed to delete a virtual host");
122122

@@ -139,7 +139,7 @@ fn test_amqp091_shovel_declaration_and_deletion() -> Result<(), Box<dyn std::err
139139
"shovels",
140140
"declare_amqp091",
141141
"--name",
142-
&name,
142+
name,
143143
"--source-uri",
144144
&amqp_endpoint,
145145
"--destination-uri",
@@ -150,8 +150,8 @@ fn test_amqp091_shovel_declaration_and_deletion() -> Result<(), Box<dyn std::err
150150
dest_x,
151151
]);
152152

153-
run_succeeds(["-V", vh, "shovels", "delete", "--name", &name]);
154-
run_succeeds(["-V", vh, "shovels", "delete", "--name", &name]);
153+
run_succeeds(["-V", vh, "shovels", "delete", "--name", name]);
154+
run_succeeds(["-V", vh, "shovels", "delete", "--name", name]);
155155

156156
delete_vhost(vh).expect("failed to delete a virtual host");
157157

@@ -181,7 +181,7 @@ fn test_amqp10_shovel_declaration_and_deletion() -> Result<(), Box<dyn std::erro
181181
"shovels",
182182
"declare_amqp10",
183183
"--name",
184-
&name,
184+
name,
185185
"--source-uri",
186186
&amqp_endpoint,
187187
"--destination-uri",
@@ -192,8 +192,8 @@ fn test_amqp10_shovel_declaration_and_deletion() -> Result<(), Box<dyn std::erro
192192
format!("/queue/{}", dest_q).as_str(),
193193
]);
194194

195-
run_succeeds(["-V", vh, "shovels", "delete", "--name", &name]);
196-
run_succeeds(["-V", vh, "shovels", "delete", "--name", &name]);
195+
run_succeeds(["-V", vh, "shovels", "delete", "--name", name]);
196+
run_succeeds(["-V", vh, "shovels", "delete", "--name", name]);
197197

198198
delete_vhost(vh).expect("failed to delete a virtual host");
199199

0 commit comments

Comments
 (0)