wo hat storm BaseBasicBolt ack() func behandelt?

Question

Wie wir wissen, müssen wir ack() Funktion nicht aufrufen.

Aber ich gehe durch den Code BaeBasicBolt, IBasicCode, kann keinen Implementierungscode finden.

Also frage ich mich, wie die ack() Methode in BasicBolt aufgerufen wird?

Answer 1

Ich finde es heraus.

Bei TopologyBuilder.setBolt() gibt es einen BasicBoltExecutor, der die Ack- und Fail-Logik übergibt.