Set accepted outcome for successful commit and rollback.
This commit is contained in:
Timothy Bish 2014-03-19 12:52:07 -04:00
parent 6056fde7ed
commit e06e23b9f3
1 changed files with 2 additions and 0 deletions

View File

@ -688,6 +688,8 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter {
Rejected rejected = new Rejected(); Rejected rejected = new Rejected();
rejected.setError(createErrorCondition("failed", er.getException().getMessage())); rejected.setError(createErrorCondition("failed", er.getException().getMessage()));
delivery.disposition(rejected); delivery.disposition(rejected);
} else {
delivery.disposition(Accepted.getInstance());
} }
LOG.debug("TX: {} settling {}", operation, action); LOG.debug("TX: {} settling {}", operation, action);
delivery.settle(); delivery.settle();