我们知道，使用 BaseBasicBolt ，我们不需要打电话 ack() 功能。但当我通过密码 BaeBasicBolt , IBasicCode ，找不到任何代码的实现。所以，我想知道 ack() 方法正在被调用 BasicBolt ?
BaseBasicBolt
ack()
BaeBasicBolt
IBasicCode
BasicBolt
kpbwa7wx1#
我找到了。什么时候 TopologyBuilder.setBolt() 完成后，有一个 BasicBoltExecutor 处理 ack 以及 fail 逻辑。
TopologyBuilder.setBolt()
BasicBoltExecutor
ack
fail
1条答案
按热度按时间kpbwa7wx1#
我找到了。
什么时候
TopologyBuilder.setBolt()完成后，有一个BasicBoltExecutor处理ack以及fail逻辑。