Skip to content

Commit cc53138

Browse files
authored
Handle more queue types in QueueTypeConverter (#1703)
1 parent 5cc1c70 commit cc53138

2 files changed

Lines changed: 7 additions & 2 deletions

File tree

src/NServiceBus.Transport.RabbitMQ/Administration/ManagementApi/Converters/QueueTypeConverter.cs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,8 @@ public override QueueType Read(ref Utf8JsonReader reader, Type typeToConvert, Js
1717
"quorum" => QueueType.Quorum,
1818
"classic" => QueueType.Classic,
1919
"stream" => QueueType.Stream,
20-
_ => throw new JsonException($"Unknown queue type: {value}")
20+
"rabbit_mqtt_qos0_queue" => QueueType.MqttQos0,
21+
_ => QueueType.Unknown
2122
};
2223
}
2324

@@ -28,6 +29,8 @@ public override void Write(Utf8JsonWriter writer, QueueType queueType, JsonSeria
2829
QueueType.Quorum => "quorum",
2930
QueueType.Classic => "classic",
3031
QueueType.Stream => "stream",
32+
QueueType.MqttQos0 => "rabbit_mqtt_qos0_queue",
33+
QueueType.Unknown => throw new ArgumentOutOfRangeException(nameof(queueType), "Cannot write unknown queue type"),
3134
_ => throw new ArgumentOutOfRangeException(nameof(queueType), $"QueueType value out of range: {queueType}")
3235
};
3336

src/NServiceBus.Transport.RabbitMQ/Administration/ManagementApi/Models/QueueType.cs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,9 @@
44
// by the NServiceBus transport, which doesn't include the `Stream` value
55
enum QueueType
66
{
7+
Unknown,
78
Classic,
89
Quorum,
9-
Stream
10+
Stream,
11+
MqttQos0
1012
}

0 commit comments

Comments
 (0)