We have a metered method legaced from ChannelInboundHandlerAdapter

public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
...
//where we do our metering part here:
            meterRegistry.timer(
                    "processing.handlermand.duration",
                    "command_name", commandName,
                    "success", Boolean.toString(true)
            ).record(duration, java.util.concurrent.TimeUnit.MILLISECONDS);

...

}

however, if there is an exception before this metering has happened, the

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
...
}

is thrown and we can't pass the same values we have initialized in channelRead to put metrics on the same page with attributes channel and duration, but just mark them with homegrown attribute success=false.

How to pass the values between channelRead and exceptionCaught?

We have a metered method legaced from ChannelInboundHandlerAdapter

public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
...
//where we do our metering part here:
            meterRegistry.timer(
                    "processing.handlermand.duration",
                    "command_name", commandName,
                    "success", Boolean.toString(true)
            ).record(duration, java.util.concurrent.TimeUnit.MILLISECONDS);

...

}

however, if there is an exception before this metering has happened, the

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
...
}

is thrown and we can't pass the same values we have initialized in channelRead to put metrics on the same page with attributes channel and duration, but just mark them with homegrown attribute success=false.

How to pass the values between channelRead and exceptionCaught?

• java
• prometheus
• netty
• micrometer

Share Improve this question Follow asked Nov 19, 2024 at 8:29 EljahEljah 5,27577 gold badges6060 silver badges110110 bronze badges

Add a comment  | 

1 Answer 1

Sorted by: Reset to default 0

It is possible to pass the attributes to the channel, String or Integer, they can be used for that.

Static initialization of the class:

private static final AttributeKey<Long> START_TIME_KEY = AttributeKey.valueOf("startTime");
private static final AttributeKey<String> COMMAND_NAME_KEY = AttributeKey.valueOf("commandName");

In channelRead():

    ctx.channel().attr(START_TIME_KEY).set(System.currentTimeMillis());
    String commandName = "unknown";
    ctx.channel().attr(COMMAND_NAME_KEY).set(commandName);

In exceptionCaught():

    long duration = System.currentTimeMillis() -  ctx.channel().attr(START_TIME_KEY).get();
    meterRegistry.timer(
            "processing.handlermand.duration",
            "command_name",ctx.channel().attr(COMMAND_NAME_KEY).get(),
            "success", Boolean.toString(false)
    ).record(duration, java.util.concurrent.TimeUnit.MILLISECONDS);