minghuaw / azservicebus Goto Github PK

warning: `rust_lib_azure` (lib test) generated 2 warnings (run `cargo fix --lib -p rust_lib_azure_bus --tests` to apply 2 suggestions)
    Finished `test` profile [unoptimized + debuginfo] target(s) in 2.44s
     Running unittests src\lib.rs (target\debug\deps\rust_lib_azure_bus-b9a918f953b77c77.exe)

running 1 test
test api::reciever::test::test_peek_messages ... ok

successes:

---- api::reciever::test::test_peek_messages stdout ----
Err(Error decoding from message

Caused by:
    Error decoding from message)

successes:
    api::reciever::test::test_peek_messages

test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 12.79s

registry\src\index.crates.io-6f17d22bba15001f\azservicebus-0.20.1\src\primitives\service_bus_peeked_message.rs:344:22:
internal error: entered unreachable code: Expecting a Long

use azservicebus::{
    ServiceBusClient, ServiceBusClientOptions, ServiceBusReceiverOptions, ServiceBusSenderOptions,
};

#[tokio::main]
async fn main() -> Result<()> {
   
let connection_string = "Endpoint=sb://<namespace>.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=<your shared access key>".to_owned();

let topic_name = "test".to_owned();
let subscription_name = "DSResult".to_owned();

let mut client = ServiceBusClient::new_from_connection_string( connection_string,
    ServiceBusClientOptions::default(),
)
    .await.unwrap();



let mut sender = client
    .create_sender(&topic_name, ServiceBusSenderOptions::with_subscriber(&subscription_name))
    .await.unwrap();

// Send one message
sender.send_message("Hello World").await.unwrap();


sender.dispose().await.unwrap();
client.dispose().await.unwrap();
Ok(())