Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,8 @@ public override QueueType Read(ref Utf8JsonReader reader, Type typeToConvert, Js
"quorum" => QueueType.Quorum,
"classic" => QueueType.Classic,
"stream" => QueueType.Stream,
_ => throw new JsonException($"Unknown queue type: {value}")
"rabbit_mqtt_qos0_queue" => QueueType.MqttQos0,
_ => QueueType.Unknown
};
}

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

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,9 @@
// by the NServiceBus transport, which doesn't include the `Stream` value
enum QueueType
{
Unknown,
Classic,
Quorum,
Stream
Stream,
MqttQos0
}