src/main/java/com/uber/rss/handlers/NotifyChannelInboundHandler.java [40:55]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public void channelActive(final ChannelHandlerContext ctx) throws Exception {
        super.channelActive(ctx);

        processChannelActive(ctx);
    }

    public void processChannelActive(final ChannelHandlerContext ctx) {
        connectionInfo = NettyUtils.getServerConnectionInfo(ctx);
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        try {
            if (logger.isTraceEnabled()) {
                logger.trace("Got incoming message: " + msg + ", " + connectionInfo);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/uber/rss/handlers/RegistryChannelInboundHandler.java [41:56]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public void channelActive(final ChannelHandlerContext ctx) throws Exception {
        super.channelActive(ctx);

        processChannelActive(ctx);
    }

    public void processChannelActive(final ChannelHandlerContext ctx) {
        connectionInfo = NettyUtils.getServerConnectionInfo(ctx);
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        try {
            if (logger.isTraceEnabled()) {
                logger.trace("Got incoming message: " + msg + ", " + connectionInfo);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -