diff --git a/components/camel-spring-parent/camel-spring-rabbitmq/pom.xml b/components/camel-spring-parent/camel-spring-rabbitmq/pom.xml index 45a60a49aef4e..56034fe063d31 100644 --- a/components/camel-spring-parent/camel-spring-rabbitmq/pom.xml +++ b/components/camel-spring-parent/camel-spring-rabbitmq/pom.xml @@ -93,5 +93,10 @@ camel-http test + + org.assertj + assertj-core + test + diff --git a/components/camel-spring-parent/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/integration/RabbitMQProducerInvalidExchangeIT.java b/components/camel-spring-parent/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/integration/RabbitMQProducerInvalidExchangeIT.java index efa4e5aef018c..8c60decfd5da8 100644 --- a/components/camel-spring-parent/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/integration/RabbitMQProducerInvalidExchangeIT.java +++ b/components/camel-spring-parent/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/integration/RabbitMQProducerInvalidExchangeIT.java @@ -29,6 +29,8 @@ import org.springframework.amqp.rabbit.connection.ConnectionFactory; import org.springframework.amqp.rabbit.core.RabbitAdmin; +import static org.assertj.core.api.Assertions.assertThat; + public class RabbitMQProducerInvalidExchangeIT extends RabbitMQITSupport { @Override @@ -50,7 +52,7 @@ public void testProducer() { final CamelExecutionException exception = Assertions.assertThrows(CamelExecutionException.class, () -> template.sendBody("direct:start", "Hello World")); - Assertions.assertInstanceOf(ShutdownSignalException.class, exception.getCause()); + assertThat(exception).hasRootCauseInstanceOf(ShutdownSignalException.class); } @Override