diff --git a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/RabbitTemplatePublisherCallbacksIntegrationTests2.java b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/RabbitTemplatePublisherCallbacksIntegrationTests2.java index db455e0d..36cbc991 100644 --- a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/RabbitTemplatePublisherCallbacksIntegrationTests2.java +++ b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/RabbitTemplatePublisherCallbacksIntegrationTests2.java @@ -133,11 +133,11 @@ public class RabbitTemplatePublisherCallbacksIntegrationTests2 { SimpleRoutingConnectionFactory rcf = new SimpleRoutingConnectionFactory(); rcf.setDefaultTargetConnectionFactory(this.connectionFactoryWithConfirmsEnabled); this.templateWithConfirmsEnabled.setConnectionFactory(rcf); - assertThat(this.templateWithConfirmsEnabled.invoke(template -> { + assertThat(this.templateWithConfirmsEnabled.invoke(template -> { template.convertAndSend("", ROUTE2, "foo"); template.waitForConfirmsOrDie(10_000); return true; - })).isTrue(); + })).isTrue(); } private void assertMessageCountEquals(long wanted) throws InterruptedException {