Toggle navigation
Home
io.netty.channel.socket.SocketChannel to io.netty.channel.Channel
No. of Instances - 8
No. of Commits - 3
No. of Projects - {'alluxio', 'neo4j', 'mpush'}
Hierarchy/Composition: R_SUPER_T
Primitive Info: -
NameSpace: External -> External
Mapping:
Cascading Type Change (Similar)
ChannelInitializer<SocketChannel>
to
ChannelInitializer<Channel>
Update Anonymous class
{ @Override public void initChannel( SocketChannel ch){ ch.config().setAllocator(PooledByteBufAllocator.DEFAULT); throttleGroup.install(ch); ch.closeFuture().addListener(future -> throttleGroup.uninstall(ch)); TransportSelectionHandler transportSelectionHandler=new TransportSelectionHandler(connector,sslCtx,encryptionRequired,false,logging,boltProtocolFactory,boltLogging); ch.pipeline().addLast(transportSelectionHandler); } }
to
{ @Override public void initChannel( Channel ch){ ch.config().setAllocator(PooledByteBufAllocator.DEFAULT); BoltChannel boltChannel=newBoltChannel(ch); connectionTracker.add(boltChannel); ch.closeFuture().addListener(future -> connectionTracker.remove(boltChannel)); throttleGroup.install(ch); ch.closeFuture().addListener(future -> throttleGroup.uninstall(ch)); TransportSelectionHandler transportSelectionHandler=new TransportSelectionHandler(boltChannel,sslCtx,encryptionRequired,false,logging,boltProtocolFactory); ch.pipeline().addLast(transportSelectionHandler); } }