|
18 | 18 |
|
19 | 19 | import static org.assertj.core.api.Assertions.assertThat;
|
20 | 20 | import static org.mockito.ArgumentMatchers.anyBoolean;
|
| 21 | +import static org.mockito.ArgumentMatchers.anyMap; |
| 22 | +import static org.mockito.ArgumentMatchers.anyString; |
21 | 23 | import static org.mockito.BDDMockito.given;
|
22 | 24 | import static org.mockito.BDDMockito.willReturn;
|
23 | 25 | import static org.mockito.Mockito.mock;
|
24 | 26 |
|
| 27 | +import java.io.IOException; |
| 28 | + |
25 | 29 | import org.junit.jupiter.api.Test;
|
26 | 30 |
|
27 | 31 | import org.springframework.amqp.rabbit.annotation.EnableRabbit;
|
|
37 | 41 | import org.springframework.context.annotation.Configuration;
|
38 | 42 | import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;
|
39 | 43 |
|
| 44 | +import com.rabbitmq.client.AMQP; |
40 | 45 | import com.rabbitmq.client.Channel;
|
41 | 46 |
|
42 | 47 |
|
@@ -91,13 +96,16 @@ public TestRabbitTemplate template() {
|
91 | 96 | }
|
92 | 97 |
|
93 | 98 | @Bean
|
94 |
| - public ConnectionFactory connectionFactory() { |
| 99 | + public ConnectionFactory connectionFactory() throws IOException { |
95 | 100 | ConnectionFactory factory = mock(ConnectionFactory.class);
|
96 | 101 | Connection connection = mock(Connection.class);
|
97 | 102 | Channel channel = mock(Channel.class);
|
| 103 | + AMQP.Queue.DeclareOk declareOk = mock(AMQP.Queue.DeclareOk.class); |
98 | 104 | willReturn(connection).given(factory).createConnection();
|
99 | 105 | willReturn(channel).given(connection).createChannel(anyBoolean());
|
100 | 106 | given(channel.isOpen()).willReturn(true);
|
| 107 | + given(channel.queueDeclare(anyString(), anyBoolean(), anyBoolean(), anyBoolean(), anyMap())) |
| 108 | + .willReturn(declareOk); |
101 | 109 | return factory;
|
102 | 110 | }
|
103 | 111 |
|
|
0 commit comments