Skip to content

Commit 5a7013a

Browse files
Update responses::MessagingProtocol for rabbitmq/rabbitmq-server#14256
1 parent 10ad81c commit 5a7013a

File tree

2 files changed

+9
-1
lines changed

2 files changed

+9
-1
lines changed

CHANGELOG.md

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,10 @@
22

33
## v0.44.0 (in development)
44

5-
No changes yet.
5+
### Enhancements
6+
7+
* `responses::MessagingProtocol` was updated to include a new variant, `MessagingProtocol::Local`,
8+
that represents a "protocol" used by local shovels in RabbitMQ 4.2.0 and later.
69

710

811
## v0.43.0 (Aug 19, 2025)

src/responses.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2254,13 +2254,16 @@ pub enum MessagingProtocol {
22542254
Amqp091,
22552255
#[serde(rename = "amqp10")]
22562256
Amqp10,
2257+
#[serde(rename = "local")]
2258+
Local,
22572259
}
22582260

22592261
impl fmt::Display for MessagingProtocol {
22602262
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
22612263
match self {
22622264
MessagingProtocol::Amqp091 => write!(f, "AMQP 0-9-1"),
22632265
MessagingProtocol::Amqp10 => write!(f, "AMQP 1.0"),
2266+
MessagingProtocol::Local => write!(f, "Local"),
22642267
}
22652268
}
22662269
}
@@ -2270,6 +2273,7 @@ impl From<String> for MessagingProtocol {
22702273
match value.as_str() {
22712274
"amqp091" => Self::Amqp091,
22722275
"amqp10" => Self::Amqp10,
2276+
"local" => Self::Local,
22732277
_ => Self::Amqp10,
22742278
}
22752279
}
@@ -2280,6 +2284,7 @@ impl From<MessagingProtocol> for String {
22802284
match value {
22812285
MessagingProtocol::Amqp091 => "amqp091".to_owned(),
22822286
MessagingProtocol::Amqp10 => "amqp10".to_owned(),
2287+
MessagingProtocol::Local => "local".to_owned(),
22832288
}
22842289
}
22852290
}

0 commit comments

Comments
 (0)