mirror of https://github.com/apache/activemq.git
Don't set the first message id if it's not known. It gets calcuated on the server side.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@697850 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
553deac60a
commit
93439b2853
|
@ -837,9 +837,7 @@ public class ActiveMQMessageConsumer implements MessageAvailableConsumer, StatsC
|
|||
deliveredCounter++;
|
||||
if ((0.5 * info.getPrefetchSize()) <= (deliveredCounter - additionalWindowSize)) {
|
||||
MessageAck ack = new MessageAck(md, ackType, deliveredCounter);
|
||||
if( deliveredMessages.isEmpty() ) {
|
||||
ack.setFirstMessageId(ack.getLastMessageId());
|
||||
} else {
|
||||
if( !deliveredMessages.isEmpty() ) {
|
||||
ack.setFirstMessageId(deliveredMessages.getLast().getMessage().getMessageId());
|
||||
}
|
||||
ack.setTransactionId(session.getTransactionContext().getTransactionId());
|
||||
|
|
Loading…
Reference in New Issue