private void doFail(long id) {
    if (log.isDebugEnabled()) {
      log.debug(String.format("%s - Received resend request for messages starting at %d", this, id));
    }

    // Ack all the entries before the given ID.
    doAck(id);

    // Now that all the entries before the given ID have been removed,
    // just iterate over the messages map and resend all the messages.
    Iterator<Map.Entry<Long, JsonObject>> iter = messages.entrySet().iterator();
    while (iter.hasNext()) {
      eventBus.send(inAddress, iter.next().getValue());
    }
  }
private void doFail ( long id ) { if ( log . isDebugEnabled ( ) ) { log . debug ( String . format ( "%s - Received resend request for messages starting at %d" , this , id ) ) ; } doAck ( id ) ; Iterator < Map . Entry < Long , JsonObject > > iter = messages . entrySet ( ) . iterator ( ) ; while ( iter . hasNext ( ) ) { eventBus . send ( inAddress , iter . next ( ) . getValue ( ) ) ; } }
Handles a batch fail.