@Override
public void channelActive(final ChannelHandlerContext ctx) throws Exception {
this.channel = ctx.channel();
- LOG.info("Starting session {} <-> {}.", channel.localAddress(), channel.remoteAddress());
+ LOG.info("Starting session {} <-> {}.", this.channel.localAddress(), this.channel.remoteAddress());
sessionUp();
}
}
private void sessionUp() {
- Preconditions.checkArgument(State.IDLE == state);
+ Preconditions.checkArgument(State.IDLE == this.state);
this.listener.onSessionUp(this);
this.state = State.UP;
}