#azure-sdk #azure #sdk #cloud #azure-rest #iot #wrapper

azure_messaging_servicebus

Rust wrappers around Microsoft Azure REST APIs - Service Bus crate

17 breaking releases

0.20.0 Apr 24, 2024
0.19.0 Jan 5, 2024
0.18.0 Dec 8, 2023
0.17.0 Nov 3, 2023
0.1.0 Jan 29, 2022

#2428 in Network programming

Download history 19/week @ 2024-01-27 1/week @ 2024-02-03 16/week @ 2024-02-10 44/week @ 2024-02-17 49/week @ 2024-02-24 38/week @ 2024-03-02 51/week @ 2024-03-09 11/week @ 2024-03-16 84/week @ 2024-03-23 55/week @ 2024-03-30 77/week @ 2024-04-06 39/week @ 2024-04-13 242/week @ 2024-04-20 201/week @ 2024-04-27 76/week @ 2024-05-04 31/week @ 2024-05-11

557 downloads per month

MIT license

235KB
5.5K SLoC

azure_messaging_servicebus

Azure Service Bus crate for the unofficial Microsoft Azure SDK for Rust. This crate is part of a collection of crates: for more information please refer to https://github.com/azure/azure-sdk-for-rust.

Example

use azure_messaging_servicebus::prelude::*;

#[tokio::main]
async fn main() -> azure_core::Result<()> {
    let service_bus_namespace = std::env::var("AZURE_SERVICE_BUS_NAMESPACE").expect("missing AZURE_SERVICE_BUS_NAMESPACE");
    let queue_name = std::env::var("AZURE_QUEUE_NAME").expect("missing AZURE_QUEUE_NAME");
    let policy_name = std::env::var("AZURE_POLICY_NAME").expect("missing AZURE_POLICY_NAME");
    let policy_key = std::env::var("AZURE_POLICY_KEY").expect("missing AZURE_POLICY_KEY");

    let http_client = azure_core::new_http_client();
    let mut client = QueueClient::new(
        http_client,
        service_bus_namespace,
        queue_name,
        policy_name,
        policy_key,
    )?;

    client.send_message("hello world").await?;

    let received_message = client.receive_and_delete_message().await?;
    println!("Received Message: {}", received_message);

    Ok(())
}

License: MIT

Dependencies

~7–20MB
~311K SLoC