From b018b710d1980c2d39b6fd088d20c60bc52841ad Mon Sep 17 00:00:00 2001 From: Marcin Grzejszczak Date: Sun, 19 Jan 2020 22:44:02 +0100 Subject: [PATCH] FIxed compialtion issues --- .../verifier/messaging/amqp/SpringAmqpStubMessages.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/amqp/SpringAmqpStubMessages.java b/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/amqp/SpringAmqpStubMessages.java index 8e6c45be99..59c966e8c7 100644 --- a/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/amqp/SpringAmqpStubMessages.java +++ b/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/amqp/SpringAmqpStubMessages.java @@ -29,6 +29,7 @@ import org.mockito.ArgumentMatchers; import org.springframework.amqp.core.Message; import org.springframework.amqp.core.MessageListener; import org.springframework.amqp.core.MessagePropertiesBuilder; +import org.springframework.amqp.rabbit.connection.CachingConnectionFactory; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer; import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener; @@ -171,7 +172,7 @@ public class SpringAmqpStubMessages implements MessageVerifier { // backward compatibility return true; } - return !this.rabbitProperties.isPublisherConfirms(); + return this.rabbitProperties.getPublisherConfirmType() != CachingConnectionFactory.ConfirmType.NONE; } @Override