storm-jms
storm-jms copied to clipboard
Ack logic in JMS Spout for batch
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 .