为了符合特定的rabbitmq消息代理实现,喷口尽可能快地使用和确认广播消息是至关重要的。messagebroker示例的规范坚持这样一个事实:使用者必须实现内存队列,以便在处理时间缓慢的情况下不延迟确认。在喷口和插销之间有这样一个隐含的队列吗?我必须在bolt中实现内存队列吗?
q3qa4bjr1#
在喷口和螺栓之间有一个队列,如这里所述。如果这对您没有帮助,您可以在spout和ack中创建一个内部缓冲区,只要您在该内部缓冲区中插入元组。
1条答案
按热度按时间q3qa4bjr1#
在喷口和螺栓之间有一个队列,如这里所述。
如果这对您没有帮助,您可以在spout和ack中创建一个内部缓冲区,只要您在该内部缓冲区中插入元组。