From 4063b7743c4b241ec904854bca82220248fec3fd Mon Sep 17 00:00:00 2001 From: Tim Malich Date: Mon, 13 Jul 2020 19:00:47 +0200 Subject: [PATCH] Enhance mocking in TestRabbitTemplateTests Fix exception in log fix travis Polishing --- .../rabbit/test/examples/TestRabbitTemplateTests.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/spring-rabbit-test/src/test/java/org/springframework/amqp/rabbit/test/examples/TestRabbitTemplateTests.java b/spring-rabbit-test/src/test/java/org/springframework/amqp/rabbit/test/examples/TestRabbitTemplateTests.java index 7ad8fcfe..c1323719 100644 --- a/spring-rabbit-test/src/test/java/org/springframework/amqp/rabbit/test/examples/TestRabbitTemplateTests.java +++ b/spring-rabbit-test/src/test/java/org/springframework/amqp/rabbit/test/examples/TestRabbitTemplateTests.java @@ -18,10 +18,14 @@ package org.springframework.amqp.rabbit.test.examples; import static org.assertj.core.api.Assertions.assertThat; import static org.mockito.ArgumentMatchers.anyBoolean; +import static org.mockito.ArgumentMatchers.anyMap; +import static org.mockito.ArgumentMatchers.anyString; import static org.mockito.BDDMockito.given; import static org.mockito.BDDMockito.willReturn; import static org.mockito.Mockito.mock; +import java.io.IOException; + import org.junit.jupiter.api.Test; import org.springframework.amqp.rabbit.annotation.EnableRabbit; @@ -37,6 +41,7 @@ import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.test.context.junit.jupiter.SpringJUnitConfig; +import com.rabbitmq.client.AMQP; import com.rabbitmq.client.Channel; @@ -91,13 +96,16 @@ public class TestRabbitTemplateTests { } @Bean - public ConnectionFactory connectionFactory() { + public ConnectionFactory connectionFactory() throws IOException { ConnectionFactory factory = mock(ConnectionFactory.class); Connection connection = mock(Connection.class); Channel channel = mock(Channel.class); + AMQP.Queue.DeclareOk declareOk = mock(AMQP.Queue.DeclareOk.class); willReturn(connection).given(factory).createConnection(); willReturn(channel).given(connection).createChannel(anyBoolean()); given(channel.isOpen()).willReturn(true); + given(channel.queueDeclare(anyString(), anyBoolean(), anyBoolean(), anyBoolean(), anyMap())) + .willReturn(declareOk); return factory; }