Struct Queue

pub struct Queue {
    pub name: String,
    /* private fields */
}

消息操作 API https://help.aliyun.com/document_detail/140735.html

Fields

name: String

队列名称

Implementations

impl Queue

pub fn new(name: &str, c: &Client) -> Self

Trait Implementations

impl Clone for Queue

fn clone(&self) -> Queue

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Queue

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl QueueOperation for Queue

fn send_message<'life0, 'life1, 'async_trait>( &'life0 self, m: &'life1 MessageSendRequest, ) -> Pin<Box<dyn Future<Output = Result<MessageSendResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

调用SendMessage接口发送消息到指定的队列 https://help.aliyun.com/document_detail/35134.html

fn receive_message<'life0, 'async_trait>( &'life0 self, wait_seconds: Option<i32>, ) -> Pin<Box<dyn Future<Output = Result<MessageReceiveResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

调用ReceiveMessage接口消费队列中的消息 https://help.aliyun.com/document_detail/35136.html

fn delete_message<'life0, 'life1, 'async_trait>( &'life0 self, receipt_handle: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

调用DeleteMessage接口删除已经被消费过的消息 https://help.aliyun.com/document_detail/35138.html

fn change_message_visibility<'life0, 'life1, 'async_trait>( &'life0 self, receipt_handle: &'life1 str, visibility_timeout: i32, ) -> Pin<Box<dyn Future<Output = Result<MessageVisibilityChangeResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

调用ChangeMessageVisibility接口，修改被消费过并且还处于Inactive状态的消息与其下次可被消费的时间间隔 https://help.aliyun.com/document_detail/35142.html

fn peek_message<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<MessageReceiveResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

调用PeekMessage接口查看消息 https://help.aliyun.com/document_detail/35140.html

fn batch_send_messages<'life0, 'life1, 'async_trait>( &'life0 self, ms: &'life1 Vec<MessageSendRequest>, ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageSendResponse>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

暂时不要使用 消息批量发送的时候，部分消息失败的异常没有处理 TODO

fn batch_receive_message<'life0, 'async_trait>( &'life0 self, num_of_messages: i32, wait_seconds: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<Vec<MessageReceiveResponse>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

暂时不要使用 批量处理时，部分消息失败的异常没有处理 TODO