This commit is contained in:
Timothy Bish 2013-09-19 06:59:28 -04:00
parent 8d5b9a5587
commit fba8e25563
1 changed files with 1 additions and 1 deletions

View File

@ -885,7 +885,7 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter {
private void settle(final Delivery delivery, final int ackType) throws Exception {
byte[] tag = delivery.getTag();
if (tag != null && tag.length > 0) {
if (tag != null && tag.length > 0 && delivery.remotelySettled()) {
checkinTag(tag);
}