Introduce QueueType::Unsupported

Author: michaelklishin

src/commons.rs

@@ -346,7 +346,9 @@ pub enum QueueType {
     Quorum,
     Stream,
     // Tanzu RabbitMQ-specific
-    Delayed
+    Delayed,
+    // A type this client is not aware of
+    Unsupported
 }
 
 impl From<&str> for QueueType {
@@ -356,7 +358,7 @@ impl From<&str> for QueueType {
             "quorum" => QueueType::Quorum,
             "stream" => QueueType::Stream,
             "delayed" => QueueType::Delayed,
-            _ => QueueType::Classic,
+            _ => QueueType::Unsupported,
         }
     }
 }
@@ -367,7 +369,7 @@ impl From<String> for QueueType {
             "classic" => QueueType::Classic,
             "quorum" => QueueType::Quorum,
             "stream" => QueueType::Stream,
-            _ => QueueType::Classic,
+            _ => QueueType::Unsupported,
         }
     }
 }
@@ -379,6 +381,7 @@ impl From<QueueType> for String {
             QueueType::Quorum => "quorum".to_owned(),
             QueueType::Stream => "stream".to_owned(),
             QueueType::Delayed => "delayed".to_owned(),
+            QueueType::Unsupported => "unsupported".to_owned(),
         }
     }
 }
@@ -459,6 +462,7 @@ impl From<QueueType> for PolicyTarget {
             QueueType::Quorum  => PolicyTarget::QuorumQueues,
             QueueType::Stream  => PolicyTarget::Streams,
             QueueType::Delayed => PolicyTarget::Queues,
+            QueueType::Unsupported => PolicyTarget::Queues,
         }
     }
 }

tests/unit_queue_tests.rs

@@ -32,6 +32,8 @@ fn test_unit_queue_type_from_str() {
 
     assert_eq!(QueueType::Delayed, QueueType::from("delayed"));
     assert_eq!(QueueType::Delayed, QueueType::from("Delayed"));
+
+    assert_eq!(QueueType::Unsupported, QueueType::from("%%a-non-existent-type"));
 }
 
 #[test]