void (@NotNull ChannelHandlerContext context, @NotNull ByteBuf input) { ByteBuf buffer = getBufferIfSufficient(input, UUID_LENGTH, context); if (buffer == null) { return; } UUID uuid = new UUID(buffer.readLong(), buffer.readLong()); for (BinaryRequestHandler customHandler : BinaryRequestHandler.EP_NAME.getExtensionList()) { if (uuid.equals(customHandler.getId())) { ChannelPipeline pipeline = context.pipeline(); pipeline.addLast(customHandler.getInboundHandler(context)); pipeline.addLast(ChannelExceptionHandler.getInstance()); pipeline.remove(this); context.fireChannelRead(buffer); break; } } }