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