From d94140558a7027999e76f94d36a238179a65cee5 Mon Sep 17 00:00:00 2001
From: minghuaw <michael.wu1107@gmail.com>
Date: Sat, 23 Sep 2023 18:13:24 -0700
Subject: [PATCH] update fe2o3-amqp-ws to 0.4.0

---
 sdk/messaging_servicebus/CHANGELOG.md                 | 6 ++++++
 sdk/messaging_servicebus/Cargo.toml                   | 4 ++--
 sdk/messaging_servicebus/examples/receive_messages.rs | 4 ++--
 3 files changed, 10 insertions(+), 4 deletions(-)

diff --git a/sdk/messaging_servicebus/CHANGELOG.md b/sdk/messaging_servicebus/CHANGELOG.md
index 739221c7dd..48e9a6dbec 100644
--- 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
index 60bf15700d..6518f323b9 100644
--- 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
index 726d8af158..cd9f5da47c 100644
--- 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