Configurable subscriber lease deadline #4947
Description
We have this thing hardcoded to 10 minutes. Some applications take longer to process a message. So this needs to be configurable as a builder option.
I would call it:
impl Subscribe {
/// Sets the maximum lease deadline.
///
/// This represents how long the application has to ack or nack a message.
/// If the client holds a message for this long, it will consider the
/// message expired, and nack it.
///
/// The default value is 10 minutes. If it takes your application longer
/// than 10 minutes to process a message, you should increase this value.
pub fn set_max_deadline(mut self, v: Duration) -> Self;
}