@Override
public void ack(QueueEntryPointer entryPointer, QueueConsumer consumer, ReadPointer readPointer)
throws OperationException {
ackInternal(entryPointer, consumer, readPointer);
if(consumer.isStateful()) {
<BUG>consumer.getQueueState().setActiveEntryId(INVALID_ENTRY_ID);
</BUG>
}
}
public void ackInternal(QueueEntryPointer entryPointer, QueueConsumer consumer, ReadPointer readPointer)

@Override
public void ack(QueueEntryPointer entryPointer, QueueConsumer consumer, ReadPointer readPointer)
throws OperationException {
ackInternal(entryPointer, consumer, readPointer);
if(consumer.isStateful()) {
getQueueStateImpl(consumer.getQueueState()).setActiveEntryId(INVALID_ENTRY_ID);
}
}
public void ackInternal(QueueEntryPointer entryPointer, QueueConsumer consumer, ReadPointer readPointer)
