Related to #4868
The default shutdown behavior should be WaitForProcessing from #4868. We have something closer to NackImmediately.
We should change the implementation so that WaitForProcessing is the default. That leads to the best customer experience.
Note that this issue tracks setting the default behavior, not making the shutdown behavior configurable.
It will take non-trivial changes to accomplish this. The lease loop needs to exit, not when message_tx is dropped, but when the last ack_tx is dropped.
|
None => break shutdown(state, ack_rx).await, |
Related to #4868
The default shutdown behavior should be
WaitForProcessingfrom #4868. We have something closer toNackImmediately.We should change the implementation so that
WaitForProcessingis the default. That leads to the best customer experience.Note that this issue tracks setting the default behavior, not making the shutdown behavior configurable.
It will take non-trivial changes to accomplish this. The lease loop needs to exit, not when
message_txis dropped, but when the lastack_txis dropped.google-cloud-rust/src/pubsub/src/subscriber/lease_loop.rs
Line 52 in cbb9fae