storm-jms icon indicating copy to clipboard operation
storm-jms copied to clipboard

Ack logic in JMS Spout for batch

Open ghost opened this issue 9 years ago • 0 comments

The ack logic in JMS Spout says :

    Message msg = this.pendingMessages.remove(msgId);
    JmsMessageID oldest = this.toCommit.first();
    if(msgId.equals(oldest)) { ... }

Is this "if" check for Batch acknowledgment mode as it does for a batch only .

ghost avatar Oct 28 '15 12:10 ghost