class ConnectionStats implements MessageStats {

  @Override
  public void decMessagesBeingReceived(int bytes) {
    stats.incInt(messagesBeingReceivedId, -1);
    if (bytes > 0) {
      stats.incLong(messageBytesBeingReceivedId, -bytes);
    }
  }

  public  ConnectionStats(StatisticsFactory factory, String prefix, String name,
      PoolStats poolStats);

}