/// Push message to queue.
///
/// Requires message body. Offset, max tries, timeout, delay are optional.
///
/// Returns empty response.
Push message to queue.
Requires message body. Offset, max tries, timeout, delay are optional.

Returns empty response.
Push message to queue . Requires message body . Offset max tries timeout delay are optional . Returns empty response .
pub async fn push(manager: Arc<Manager<'_>>, name: String, request: PushRequest) -> Result<Json> {
    let queue = manager.queue(&name)?;
    let message: Message = request.try_into().map_err(QueueError::MessageCompose)?;
    queue
        .log_event(&name, &manager, Event::Push(MaybeOwned::Borrowed(&message)))
        .await?;
    queue.database().await.push(message);
    Ok(json(&()))
}
pub async fn push ( manager : Arc < Manager < ' _ > > , name : String , request : PushRequest ) -> Result < Json > { let queue = manager . queue ( & name ) ? ; let message : Message = request . try_into ( ) . map_err ( QueueError :: MessageCompose ) ? ; queue . log_event ( & name , & manager , Event :: Push ( MaybeOwned :: Borrowed ( & message ) ) ) . await ? ; queue . database ( ) . await . push ( message ) ; Ok ( json ( & ( ) ) ) }
Push message to queue.
Push message to queue .
manager
Arc<Manager<'_>>
name
String
request
PushRequest