Add two more operations to QueueOps

Author: michaelklishin

CHANGELOG.md

@@ -6,7 +6,9 @@
 
  * `QueueOps#x_arguments` is a new method that returns the optional arguments of an object (`XArguments`)
  * `QueueOps#has_queue_ttl_arg` is a new method that returns true if optional arguments of an object include a queue TTL argument (`"x-expires"`)
- * `QueueOps#has_message_ttl_arg` is a new method that returns true if optional arguments of an object include a message TTL argument (`"x-message-ttl"`)
+ * `QueueOps#has_message_ttl_arg`: returns true if optional arguments of an object include a message TTL argument (`"x-message-ttl"`)
+ * `QueueOps#has_length_limit_in_messages`: returns true if optional arguments of an object include a queue length limit in messages (`"x-max-length"`)
+ * `QueueOps#has_length_limit_in_bytes`: returns true if optional arguments of an object include a queue length limit in bytes (`"x-max-length-bytes"`)
 
 
 

src/responses.rs

@@ -71,6 +71,8 @@ impl XArguments {
     ];
     pub const X_EXPIRES_KEY: &'static str = "x-expires";
     pub const X_MESSAGE_TTL_KEY: &'static str = "x-message-ttl";
+    pub const X_MAX_LENGTH_KEY: &'static str = "x-max-length";
+    pub const X_MAX_LENGTH_BYTES_KEY: &'static str = "x-max-length-bytes";
 
     pub fn get(&self, key: &str) -> Option<&serde_json::Value> {
         self.0.get(key)
@@ -790,6 +792,14 @@ pub trait QueueOps {
         self.x_arguments()
             .contains_key(XArguments::X_MESSAGE_TTL_KEY)
     }
+
+    fn has_length_limit_in_messages(&self) -> bool {
+        self.x_arguments().contains_key(XArguments::X_MAX_LENGTH_KEY)
+    }
+
+    fn has_length_limit_in_bytes(&self) -> bool {
+        self.x_arguments().contains_key(XArguments::X_MAX_LENGTH_BYTES_KEY)
+    }
 }
 
 #[derive(Debug, Deserialize, Clone)]