Crate mns

Source
Expand description

Aliyun Message Service (MNS) SDK for Rust docs.rs

§Example

use mns::Client;
use mns::Queue;
use mns::queue::{ MessageSendRequest, QueueOperation };
#[tokio::main]
async fn main() {
let client = Client::new("https://xxx.mns.cn-hangzhou.aliyuncs.com", "your id", "your key");
    let queue = Queue::new("your queue name", &client);
    queue.send_message(&MessageSendRequest {
        message_body: "aa".to_string(),
        delay_seconds: Some(1),
        priority: Some(9),
    }).await.unwrap();
}

Modules§

client
consumer
Consumer 参考 Lapin 的 Consumer 实现，使用 tokio 进行异步处理
error
options
queue
消息操作 API，包括消息的发送、接收、删除、修改可见性等操作 https://help.aliyun.com/document_detail/140735.html
queue_manager
队列管理实例 https://help.aliyun.com/document_detail/140734.html

Type Aliases§

Client
Queue
消息操作 API，包括消息的发送、接收、删除、修改可见性等操作 https://help.aliyun.com/document_detail/140735.html
QueueManager