public class Session extends AbstractProtocolSession<SimpleMessage> {
- private static final Logger logger = LoggerFactory.getLogger(Session.class);
+ private static final Logger LOG = LoggerFactory.getLogger(Session.class);
public final List<SimpleMessage> msgs = Lists.newArrayList();
@Override
public void handleMessage(final SimpleMessage msg) {
- logger.debug("Message received: {}", msg.getMessage());
+ LOG.debug("Message received: {}", msg.getMessage());
this.up = true;
this.msgs.add(msg);
- logger.debug(this.msgs.size() + "");
+ LOG.debug(this.msgs.size() + "");
}
@Override
public void endOfInput() {
- logger.debug("End of input reported.");
+ LOG.debug("End of input reported.");
}
@Override
protected void sessionUp() {
- logger.debug("Session up reported.");
+ LOG.debug("Session up reported.");
}
}
import com.google.common.base.Preconditions;
public class SimpleDispatcher extends AbstractDispatcher<SimpleSession, SimpleSessionListener> {
- private static final Logger logger = LoggerFactory.getLogger(SimpleDispatcher.class);
+ private static final Logger LOG = LoggerFactory.getLogger(SimpleDispatcher.class);
private final SessionNegotiatorFactory<SimpleMessage, SimpleSession, SimpleSessionListener> negotiatorFactory;
private final ChannelOutboundHandler encoder = new SimpleMessageToByteEncoder();
channel.pipeline().addLast(new SimpleByteToMessageDecoder());
channel.pipeline().addLast("negotiator", negotiatorFactory.getSessionNegotiator(listenerFactory, channel, promise));
channel.pipeline().addLast(encoder);
- logger.debug("initialization completed for channel {}", channel);
+ LOG.debug("initialization completed for channel {}", channel);
}
}
* Simple Session Listener that is notified about messages and changes in the session.
*/
public class SimpleSessionListener implements SessionListener<SimpleMessage, SimpleSession, TerminationReason> {
- private static final Logger logger = LoggerFactory.getLogger(SimpleSessionListener.class);
+ private static final Logger LOG = LoggerFactory.getLogger(SimpleSessionListener.class);
public List<SimpleMessage> messages = new ArrayList<>();
@Override
public void onMessage(final SimpleSession session, final SimpleMessage message) {
- logger.debug("Received message: " + message.getClass() + " " + message);
+ LOG.debug("Received message: " + message.getClass() + " " + message);
this.messages.add(message);
}