search

ptgoetz / storm-jms

Storm JMS Integration
Apache License 2.0
78 stars 66 forks source link

Ack logic in JMS Spout for batch #25

Open ghost opened 9 years ago

ghost commented 9 years ago

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 .