Skip to content

Commit

Permalink
Disable quorum test temporarily
Browse files Browse the repository at this point in the history
  • Loading branch information
garyrussell committed Nov 6, 2019
1 parent 6edcac7 commit 179fcd8
Showing 1 changed file with 13 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,7 @@

import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;

import org.springframework.amqp.core.Binding;
Expand Down Expand Up @@ -174,6 +175,7 @@ void testQueueArgs3() throws MalformedURLException, URISyntaxException, Interrup
* Does not require a 3.8 broker - they are just arbitrary arguments.
*/
@Test
@Disabled("Until the quorum_queue feature flag is enabled on Bamboo")
void testQuorumArgs() throws MalformedURLException, URISyntaxException, InterruptedException {
Client client = new Client(brokerRunning.getAdminUri(), brokerRunning.getAdminUser(),
brokerRunning.getAdminPassword());
Expand Down Expand Up @@ -289,9 +291,9 @@ public Queue requestQueue() {
@Bean
public Queue replyQueue() {
return QueueBuilder.nonDurable("dlx.test.replyQ")
.autoDelete()
.withArgument("x-dead-letter-exchange", "reply.dlx")
.build();
.autoDelete()
.withArgument("x-dead-letter-exchange", "reply.dlx")
.build();
}

/**
Expand Down Expand Up @@ -352,13 +354,13 @@ public Queue allArgs3() {
.build();
}

@Bean
public Queue quorum() {
return QueueBuilder.durable("test.quorum")
.quorum()
.deliveryLimit(10)
.build();
}
// @Bean
// public Queue quorum() {
// return QueueBuilder.durable("test.quorum")
// .quorum()
// .deliveryLimit(10)
// .build();
// }

@Bean
public DeadListener deadListener() {
Expand Down Expand Up @@ -396,6 +398,7 @@ public String handleMessage(String foo) throws Exception {
}

public static class DeadListener {

private final CountDownLatch latch = new CountDownLatch(1);

public void handleMessage(@SuppressWarnings("unused") String foo) {
Expand Down

0 comments on commit 179fcd8

Please sign in to comment.