channelInactive() — netty Function Reference

Architecture documentation for the channelInactive() function in MessageAggregator.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ channelInactive() — netty Function Reference

Dependency Diagram

graph TD
  dd9e7345_b69c_3d38_88c7_9302607ff525["channelInactive()"]
  5eb281df_9169_db16_7477_6d4eba81b483["MessageAggregator"]
  dd9e7345_b69c_3d38_88c7_9302607ff525 -->|defined in| 5eb281df_9169_db16_7477_6d4eba81b483
  b20bcd97_0ac8_de99_7f59_4305e6017dd1["releaseCurrentMessage()"]
  dd9e7345_b69c_3d38_88c7_9302607ff525 -->|calls| b20bcd97_0ac8_de99_7f59_4305e6017dd1
  style dd9e7345_b69c_3d38_88c7_9302607ff525 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-base/src/main/java/io/netty/handler/codec/MessageAggregator.java lines 430–442

    @Override
    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
        if (aggregating && handleIncompleteAggregateDuringClose) {
            ctx.fireExceptionCaught(
                    new PrematureChannelClosureException("Channel closed while still aggregating message"));
        }
        try {
            // release current message if it is not null as it may be a left-over
            super.channelInactive(ctx);
        } finally {
            releaseCurrentMessage();
        }
    }