pub async fn requeue(
    manager: Arc<Manager<'_>>,
    name: String,
    request: RequeueRequest,
) -> Result<Json> {
    let queue = manager.queue(&name)?;

    queue
        .log_event(&name, &manager, Event::Requeue(request.id))
        .await?;

    queue
        .database()
        .await
        .requeue(request.id)
        .ok_or(QueueError::MessageNotFound)?;

    Ok(json(&()))
}
/// Requeues message back to queue.
///
/// Requires ID of message being requeued, returns empty response.
///
/// Message try counter is incremented.
Requeues message back to queue.
Requires ID of message being requeued, returns empty response.

Message try counter is incremented.
Requeues message back to queue . Requires ID of message being requeued returns empty response . Message try counter is incremented .
pub async fn requeue(
    manager: Arc<Manager<'_>>,
    name: String,
    request: RequeueRequest,
) -> Result<Json> {
    let queue = manager.queue(&name)?;
    queue
        .log_event(&name, &manager, Event::Requeue(request.id))
        .await?;
    queue
        .database()
        .await
        .requeue(request.id)
        .ok_or(QueueError::MessageNotFound)?;
    Ok(json(&()))
}
pub async fn requeue ( manager : Arc < Manager < ' _ > > , name : String , request : RequeueRequest , ) -> Result < Json > { let queue = manager . queue ( & name ) ? ; queue . log_event ( & name , & manager , Event :: Requeue ( request . id ) ) . await ? ; queue . database ( ) . await . requeue ( request . id ) . ok_or ( QueueError :: MessageNotFound ) ? ; Ok ( json ( & ( ) ) ) }
Requeues message back to queue.
Requeues message back to queue .
manager
Arc<Manager<'_>>
name
String
request
RequeueRequest
manager
Arc<Manager<'_>>
name
String
request
RequeueRequest