private void doAck(long id) {
    // The other side of the connection has sent a message indicating which
    // messages it has seen. We can clear any messages before the indicated ID.
    if (log.isDebugEnabled()) {
      log.debug(String.format("%s - Received ack for messages up to %d, removing all previous messages from memory", this, id));
    }
    if (messages.containsKey(id+1)) {
      messages.tailMap(id+1);
    } else {
      messages.clear();
    }
    checkDrain();
  }
private void doAck ( long id ) { if ( log . isDebugEnabled ( ) ) { log . debug ( String . format ( "%s - Received ack for messages up to %d, removing all previous messages from memory" , this , id ) ) ; } if ( messages . containsKey ( id + 1 ) ) { messages . tailMap ( id + 1 ) ; } else { messages . clear ( ) ; } checkDrain ( ) ; }
Handles a batch ack.