Skip to content

Commit d06e75e

Browse files
committed
Fix new test class for the current state of code
https://build.spring.io/browse/AMQP-R22X-84/
1 parent de1cf7e commit d06e75e

File tree

1 file changed

+3
-14
lines changed

1 file changed

+3
-14
lines changed

spring-rabbit/src/test/java/org/springframework/amqp/rabbit/connection/ConnnectionListenerTests.java renamed to spring-rabbit/src/test/java/org/springframework/amqp/rabbit/connection/ConnectionListenerTests.java

Lines changed: 3 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -27,29 +27,18 @@
2727

2828
/**
2929
* @author Gary Russell
30+
* @author Artem Bilan
3031
* @since 2.2.17
3132
*
3233
*/
33-
public class ConnnectionListenerTests {
34+
public class ConnectionListenerTests {
3435

3536
@Test
3637
void cantConnectCCF() {
3738
CachingConnectionFactory ccf = new CachingConnectionFactory(rcf());
3839
cantConnect(ccf);
3940
}
4041

41-
@Test
42-
void cantConnectTCCF() {
43-
ThreadChannelConnectionFactory tccf = new ThreadChannelConnectionFactory(rcf());
44-
cantConnect(tccf);
45-
}
46-
47-
@Test
48-
void cantConnectPCCF() {
49-
PooledChannelConnectionFactory pccf = new PooledChannelConnectionFactory(rcf());
50-
cantConnect(pccf);
51-
}
52-
5342
private com.rabbitmq.client.ConnectionFactory rcf() {
5443
com.rabbitmq.client.ConnectionFactory rcf = new com.rabbitmq.client.ConnectionFactory();
5544
rcf.setHost("junk.host");
@@ -70,7 +59,7 @@ public void onFailed(Exception exception) {
7059
}
7160

7261
});
73-
assertThatExceptionOfType(AmqpIOException.class).isThrownBy(() -> cf.createConnection());
62+
assertThatExceptionOfType(AmqpIOException.class).isThrownBy(cf::createConnection);
7463
assertThat(failed.get()).isTrue();
7564
}
7665

0 commit comments

Comments
 (0)