This commit is contained in:
@@ -118,7 +118,7 @@ async fn main()->Result<(),StartupError>{
|
|||||||
name:Some(DURABLE_NAME.to_owned()),
|
name:Some(DURABLE_NAME.to_owned()),
|
||||||
durable_name:Some(DURABLE_NAME.to_owned()),
|
durable_name:Some(DURABLE_NAME.to_owned()),
|
||||||
filter_subjects:filter_subjects.clone(),
|
filter_subjects:filter_subjects.clone(),
|
||||||
ack_wait:std::time::Duration::from_secs(300), // 5 minutes for processing
|
ack_wait:std::time::Duration::from_secs(900), // 15 minutes for processing
|
||||||
max_deliver:5, // retry up to 5 times
|
max_deliver:5, // retry up to 5 times
|
||||||
..Default::default()
|
..Default::default()
|
||||||
};
|
};
|
||||||
|
|||||||
Reference in New Issue
Block a user