@@ -35,9 +35,8 @@ implementation("io.opentelemetry.instrumentation:opentelemetry-netty-4.1:OPENTEL
3535import io.netty.bootstrap.Bootstrap ;
3636import io.netty.channel.Channel ;
3737import io.netty.channel.ChannelInitializer ;
38- import io.netty.channel.nio.NioEventLoopGroup ;
38+ import io.netty.channel.EventLoopGroup ;
3939import io.netty.channel.socket.SocketChannel ;
40- import io.netty.channel.socket.nio.NioSocketChannel ;
4140import io.netty.handler.codec.http.HttpClientCodec ;
4241import io.opentelemetry.api.OpenTelemetry ;
4342import io.opentelemetry.context.Context ;
@@ -48,16 +47,19 @@ OpenTelemetry openTelemetry = ...;
4847
4948NettyClientTelemetry clientTelemetry = NettyClientTelemetry . create(openTelemetry);
5049
50+ EventLoopGroup eventLoopGroup = ... ; // Use appropriate EventLoopGroup for your platform
51+ Class<? extends Channel > channelClass = ... ; // Use appropriate Channel class for your platform
52+
5153Bootstrap bootstrap = new Bootstrap ();
52- bootstrap. group(new NioEventLoopGroup () )
53- .channel(NioSocketChannel . class )
54+ bootstrap. group(eventLoopGroup )
55+ .channel(channelClass )
5456 .handler(new ChannelInitializer<SocketChannel > () {
5557 @Override
5658 protected void initChannel (SocketChannel ch ) {
5759 ch. pipeline()
5860 .addLast(new HttpClientCodec ())
59- .addLast(clientTelemetry. createRequestHandler ())
60- .addLast(clientTelemetry . createResponseHandler ());
61+ .addLast(clientTelemetry. createCombinedHandler ())
62+ .addLast(new YourClientHandler ()); // Your application handler
6163 }
6264 });
6365
@@ -71,9 +73,8 @@ NettyClientTelemetry.setChannelContext(channel, Context.current());
7173import io.netty.bootstrap.ServerBootstrap ;
7274import io.netty.channel.ChannelInitializer ;
7375import io.netty.channel.EventLoopGroup ;
74- import io.netty.channel.nio.NioEventLoopGroup ;
76+ import io.netty.channel.ServerChannel ;
7577import io.netty.channel.socket.SocketChannel ;
76- import io.netty.channel.socket.nio.NioServerSocketChannel ;
7778import io.netty.handler.codec.http.HttpServerCodec ;
7879import io.opentelemetry.api.OpenTelemetry ;
7980import io.opentelemetry.instrumentation.netty.v4_1.NettyServerTelemetry ;
@@ -83,19 +84,20 @@ OpenTelemetry openTelemetry = ...;
8384
8485NettyServerTelemetry serverTelemetry = NettyServerTelemetry . create(openTelemetry);
8586
86- EventLoopGroup bossGroup = new NioEventLoopGroup ();
87- EventLoopGroup workerGroup = new NioEventLoopGroup ();
87+ EventLoopGroup bossGroup = ... ; // Use appropriate EventLoopGroup for your platform
88+ EventLoopGroup workerGroup = ... ; // Use appropriate EventLoopGroup for your platform
89+ Class<? extends ServerChannel > serverChannelClass = ... ; // Use appropriate ServerChannel class for your platform
8890
8991ServerBootstrap bootstrap = new ServerBootstrap ();
9092bootstrap. group(bossGroup, workerGroup)
91- .channel(NioServerSocketChannel . class )
93+ .channel(serverChannelClass )
9294 .childHandler(new ChannelInitializer<SocketChannel > () {
9395 @Override
9496 protected void initChannel (SocketChannel ch ) {
9597 ch. pipeline()
9698 .addLast(new HttpServerCodec ())
97- .addLast(serverTelemetry. createRequestHandler ())
98- .addLast(serverTelemetry . createResponseHandler ());
99+ .addLast(serverTelemetry. createCombinedHandler ())
100+ .addLast(new YourServerHandler ()); // Your application handler
99101 }
100102 });
101103
0 commit comments