Skip to content

Commit 79d9c7c

Browse files
committed
Add test condition on message status
A message can be rejected because the queue is considered unavailable during its deletion.
1 parent face8af commit 79d9c7c

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/test/java/com/rabbitmq/client/amqp/impl/ResourceListenerTest.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
1818
package com.rabbitmq.client.amqp.impl;
1919

20+
import static com.rabbitmq.client.amqp.Publisher.Status.REJECTED;
2021
import static com.rabbitmq.client.amqp.Publisher.Status.RELEASED;
2122
import static org.assertj.core.api.Assertions.anyOf;
2223
import static org.assertj.core.api.Assertions.fail;
@@ -95,8 +96,10 @@ void publisherIsClosedOnExchangeDeletion(boolean toExchange, TestInfo info)
9596
.is(
9697
anyOf(
9798
new Condition<>(s -> outboundMessageStatus.isEmpty(), "no status"),
98-
new Condition<>(s -> outboundMessageStatus.contains(RELEASED), "only released")));
99-
// Assertions.assertThat(outboundMessageStatus).containsOnly(Publisher.Status.FAILED);
99+
new Condition<>(s -> outboundMessageStatus.contains(RELEASED), "released"),
100+
new Condition<>(
101+
s -> outboundMessageStatus.contains(REJECTED),
102+
"rejected (queue may be considered unavailable during deletion)")));
100103
Assertions.assertThat(closedCause.get()).isNotNull().isInstanceOf(AmqpException.class);
101104
}
102105

0 commit comments

Comments
 (0)