Skip to content

Commit

Permalink
Fix netty transport substitution
Browse files Browse the repository at this point in the history
  • Loading branch information
ryanemerson committed Apr 6, 2021
1 parent cafe2a3 commit 8fba4fe
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,16 +19,16 @@
import java.util.concurrent.ExecutorService;

@Substitute
@TargetClass(className = "org.infinispan.client.hotrod.impl.transport.netty.TransportHelper")
@TargetClass(className = "org.infinispan.client.hotrod.impl.transport.netty.DefaultTransportFactory")
final class SubstituteTransportHelper {

@Substitute
static Class<? extends SocketChannel> socketChannel() {
public Class<? extends SocketChannel> socketChannelClass() {
return NioSocketChannel.class;
}

@Substitute
static EventLoopGroup createEventLoopGroup(int maxExecutors, ExecutorService executorService) {
public EventLoopGroup createEventLoopGroup(int maxExecutors, ExecutorService executorService) {
return new NioEventLoopGroup(maxExecutors, executorService);
}
}
Expand Down

0 comments on commit 8fba4fe

Please sign in to comment.