822823824825826827828829830831832
throw new IllegalStateException("Cannot find ref to ack " + messageID); } if(!failed) { ref.decrementDeliveryCount(); } ref.getQueue().cancel(ref, System.currentTimeMillis()); }
812813814815816817818819820821822
799800801802803804805806807808809
820821822823824825826827828829830
throw new IllegalStateException("Cannot find ref to ack " + messageID); } if (!failed) { ref.decrementDeliveryCount(); } ref.getQueue().cancel(ref, System.currentTimeMillis()); }