async fn handle_catch_up_request(
service: Arc<RedisMessageStorage>,
request: CatchUpRequest,
sender: UnboundedSender<CatchUpResponse>,
) -> Result<(), MessageStoreError>async fn handle_catch_up_request(
service: Arc<RedisMessageStorage>,
request: CatchUpRequest,
sender: UnboundedSender<CatchUpResponse>,
) -> Result<(), MessageStoreError>