Skip to content

Commit c7230f8

Browse files
committed
fix(datashare-tasks): improve AmqpTest debugging
1 parent 2bf6c7c commit c7230f8

File tree

1 file changed

+1
-1
lines changed
  • datashare-tasks/src/test/java/org/icij/datashare/asynctasks/bus/amqp

1 file changed

+1
-1
lines changed

datashare-tasks/src/test/java/org/icij/datashare/asynctasks/bus/amqp/AmqpTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ public void test_consume_nack_without_requeue() throws Exception {
117117
new AmqpConsumer<>(amqp, nackExceptionConsumer, AmqpQueue.EVENT, TestEvent.class ).consumeEvents(1);
118118
new AmqpConsumer<>(amqp, new TestEventConsumer(), AmqpQueue.MANAGER_EVENT, TestEvent.class).consumeEvents(1);
119119

120-
amqp.publish(AmqpQueue.EVENT, new TestEvent("boom!!"));
120+
amqp.publish(AmqpQueue.EVENT, new TestEvent("boom no requeue !!"));
121121

122122
TestEvent polled = eventQueue.poll(1, TimeUnit.SECONDS);
123123
String asString = Optional.ofNullable(polled).map(rethrowFunction(JsonObjectMapper::writeValueAsString)).orElse(null);

0 commit comments

Comments
 (0)