|
26 | 26 |
|
27 | 27 | import org.junit.jupiter.api.AfterAll;
|
28 | 28 | import org.junit.jupiter.api.BeforeAll;
|
29 |
| -import org.junit.jupiter.api.Disabled; |
30 | 29 | import org.junit.jupiter.api.Test;
|
31 | 30 |
|
32 | 31 | import org.springframework.amqp.core.Binding;
|
@@ -175,7 +174,6 @@ void testQueueArgs3() throws MalformedURLException, URISyntaxException, Interrup
|
175 | 174 | * Does not require a 3.8 broker - they are just arbitrary arguments.
|
176 | 175 | */
|
177 | 176 | @Test
|
178 |
| - @Disabled("Until the quorum_queue feature flag is enabled on Bamboo") |
179 | 177 | void testQuorumArgs() throws MalformedURLException, URISyntaxException, InterruptedException {
|
180 | 178 | Client client = new Client(brokerRunning.getAdminUri(), brokerRunning.getAdminUser(),
|
181 | 179 | brokerRunning.getAdminPassword());
|
@@ -291,9 +289,9 @@ public Queue requestQueue() {
|
291 | 289 | @Bean
|
292 | 290 | public Queue replyQueue() {
|
293 | 291 | return QueueBuilder.nonDurable("dlx.test.replyQ")
|
294 |
| - .autoDelete() |
295 |
| - .withArgument("x-dead-letter-exchange", "reply.dlx") |
296 |
| - .build(); |
| 292 | + .autoDelete() |
| 293 | + .withArgument("x-dead-letter-exchange", "reply.dlx") |
| 294 | + .build(); |
297 | 295 | }
|
298 | 296 |
|
299 | 297 | /**
|
@@ -354,13 +352,13 @@ public Queue allArgs3() {
|
354 | 352 | .build();
|
355 | 353 | }
|
356 | 354 |
|
357 |
| -// @Bean |
358 |
| -// public Queue quorum() { |
359 |
| -// return QueueBuilder.durable("test.quorum") |
360 |
| -// .quorum() |
361 |
| -// .deliveryLimit(10) |
362 |
| -// .build(); |
363 |
| -// } |
| 355 | + @Bean |
| 356 | + public Queue quorum() { |
| 357 | + return QueueBuilder.durable("test.quorum") |
| 358 | + .quorum() |
| 359 | + .deliveryLimit(10) |
| 360 | + .build(); |
| 361 | + } |
364 | 362 |
|
365 | 363 | @Bean
|
366 | 364 | public DeadListener deadListener() {
|
@@ -398,7 +396,6 @@ public String handleMessage(String foo) throws Exception {
|
398 | 396 | }
|
399 | 397 |
|
400 | 398 | public static class DeadListener {
|
401 |
| - |
402 | 399 | private final CountDownLatch latch = new CountDownLatch(1);
|
403 | 400 |
|
404 | 401 | public void handleMessage(@SuppressWarnings("unused") String foo) {
|
|
0 commit comments