Fix TcpSenderTests for actual interceptors API

This commit is contained in:
Artem Bilan
2022-01-03 13:17:14 -05:00
parent b4a56e60b8
commit 7922c421ec

View File

@@ -25,6 +25,7 @@ import org.junit.jupiter.api.Test;
/**
* @author Gary Russell
*
* @since 5.3.10
*
*/
@@ -70,14 +71,17 @@ public class TcpSenderTests {
CountDownLatch adds = new CountDownLatch(2);
CountDownLatch removes = new CountDownLatch(2);
TcpConnectionInterceptorFactoryChain chain = new TcpConnectionInterceptorFactoryChain();
chain.setInterceptor(new HelloWorldInterceptorFactory() {
chain.setInterceptors(new TcpConnectionInterceptorFactory[] {
new HelloWorldInterceptorFactory() {
@Override
public TcpConnectionInterceptorSupport getInterceptor() {
return new TcpConnectionInterceptorSupport() {
};
}
@Override
public TcpConnectionInterceptorSupport getInterceptor() {
return new TcpConnectionInterceptorSupport() {
};
}
}
});
client.setInterceptorFactoryChain(chain);
client.registerSender(new TcpSender() {