Repository: activemq Updated Branches: refs/heads/master da076f4a6 -> c78eddce7
revert sync ack send for https://issues.apache.org/jira/browse/AMQ-3519 due to rework in https://issues.apache.org/jira/browse/AMQ-5068 - sync send no longer needed because redelivered flag is persisted before dispatch. This avoids a roundtrip overhead on individual ack, ie priority or nonBlockingRedelivery options in the mix Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/c78eddce Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/c78eddce Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/c78eddce Branch: refs/heads/master Commit: c78eddce7ed3045b5508dd6713252dca8766436c Parents: da076f4 Author: gtully <[email protected]> Authored: Fri Dec 11 17:05:49 2015 +0000 Committer: gtully <[email protected]> Committed: Fri Dec 11 17:05:49 2015 +0000 ---------------------------------------------------------------------- .../src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/c78eddce/activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java ---------------------------------------------------------------------- diff --git a/activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java b/activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java index a67022b..adbcf39 100755 --- a/activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java +++ b/activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java @@ -924,7 +924,7 @@ public class ActiveMQMessageConsumer implements MessageAvailableConsumer, StatsC registerSync(); MessageAck ack = new MessageAck(md, MessageAck.INDIVIDUAL_ACK_TYPE, 1); ack.setTransactionId(session.getTransactionContext().getTransactionId()); - session.syncSendPacket(ack); + session.sendAck(ack); } private void afterMessageIsConsumed(MessageDispatch md, boolean messageExpired) throws JMSException {
