Crates.io | azure_messaging_servicebus |
lib.rs | azure_messaging_servicebus |
version | 0.20.0 |
source | src |
created_at | 2022-01-29 14:59:09.145642 |
updated_at | 2024-04-24 16:23:05.995443 |
description | Rust wrappers around Microsoft Azure REST APIs - Service Bus crate |
homepage | https://github.com/azure/azure-sdk-for-rust |
repository | https://github.com/azure/azure-sdk-for-rust |
max_upload_size | |
id | 523654 |
size | 78,474 |
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.
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