Merge pull request #29 from minghuaw/servicebus_over_amqp

update fe2o3-amqp-ws to 0.4.0
minghuaw · Sep 24, 2023 · 768e5f7 · 768e5f7
2 parents 8ff0496 + d941405
commit 768e5f7
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 4 deletions.
diff --git a/sdk/messaging_servicebus/CHANGELOG.md b/sdk/messaging_servicebus/CHANGELOG.md
@@ -1,5 +1,11 @@
 # CHANGELOG
 
+## 0.15.1
+
+- Updated `fe2o3-amqp-ws` dependency to 0.4.0, which includes an upstream fix for [CVE-2023-43669](https://github.com/snapview/tungstenite-rs/pull/379).
+
+### Breaking Changes
+
 ## 0.15.0 - Sep. 15, 2023
 
 - Updated `azure_core` dependency to 0.15.0

diff --git a/sdk/messaging_servicebus/Cargo.toml b/sdk/messaging_servicebus/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "azservicebus"
-version = "0.15.0"
+version = "0.15.1"
 description = "An unofficial AMQP 1.0 rust client for Azure Service Bus"
 readme = "README.md"
 authors = ["Minghua Wu"]
@@ -49,7 +49,7 @@ fe2o3-amqp-types = "0.7"
 fe2o3-amqp = {version = "0.8.15"} # TODO: let user choose rustls or native-tls?
 fe2o3-amqp-cbs = "0.2"
 fe2o3-amqp-management = "0.2.1"
-fe2o3-amqp-ws = { version = "0.3.1" }
+fe2o3-amqp-ws = { version = "0.4.0" }
 serde_amqp = {version = "0.5.6", features = ["time"]}
 
 [target.'cfg(not(target_arch = "wasm32"))'.dependencies]

diff --git a/sdk/messaging_servicebus/examples/receive_messages.rs b/sdk/messaging_servicebus/examples/receive_messages.rs
@@ -8,14 +8,14 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     // which can be found in the Azure portal and should look like
     // "Endpoint=sb://<NAMESPACE>.servicebus.windows.net/;SharedAccessKeyName=<KEY_NAME>;SharedAccessKey=<KEY_VALUE>"
     let mut client = ServiceBusClient::new_from_connection_string(
-        "<NAMESPACE-CONNECTION-STRING>",
+        "Endpoint=sb://azservicebus-testing.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=f+K8k7neAdg2e29A2bh12mwRCw5rdpKBR+ASbCSYfQ8=",
         ServiceBusClientOptions::default(),
     )
     .await?;
 
     // Replace "<QUEUE-NAME>" with the name of your queue
     let mut receiver = client
-        .create_receiver_for_queue("<QUEUE-NAME>", ServiceBusReceiverOptions::default())
+        .create_receiver_for_queue("q1", ServiceBusReceiverOptions::default())
         .await?;
 
     // Receive messages from the queue