Skip to content

Commit

Permalink
Fix assertions
Browse files Browse the repository at this point in the history
  • Loading branch information
mkuratczyk committed Jun 6, 2023
1 parent 3ce2cae commit 858d844
Showing 1 changed file with 3 additions and 5 deletions.
8 changes: 3 additions & 5 deletions tests/queue_tests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ fn test_declare_a_quorum_queue() {
let _ = rc.delete_queue(&vhost, &name);

let result1 = rc.get_queue_info(&vhost, &name);
assert!(result1.is_ok(), "get_queue_info returned {:?}", result1);
assert!(!result1.is_ok());

let mut map = Map::<String, Value>::new();
map.insert("x-max-length".to_owned(), json!(10_000));
Expand All @@ -36,7 +36,7 @@ fn test_declare_a_stream() {
let _ = rc.delete_queue(&vhost, &name);

let result1 = rc.get_queue_info(&vhost, &name);
assert!(result1.is_ok(), "get_queue_info returned {:?}", result1);
assert!(!result1.is_ok());

let mut map = Map::<String, Value>::new();
map.insert("x-max-length-bytes".to_owned(), json!(10_000_000));
Expand All @@ -58,17 +58,15 @@ fn test_delete_queue() {
let _ = rc.delete_queue(&vhost, &name);

let result1 = rc.get_queue_info(&vhost, &name);
assert!(result1.is_ok(), "get_queue_info returned {:?}", result1);
assert!(!result1.is_ok());

let params = QueueParams::new_exclusive_classic_queue(&name, None);
let result2 = rc.declare_queue(&vhost, &params);
assert!(result2.is_ok());
assert!(result2.is_ok(), "declare_queue returned {:?}", result2);

let _ = rc.delete_queue(&vhost, &name);
let result3 = rc.get_queue_info(&vhost, &name);
assert!(!result3.is_ok());
assert!(result3.is_ok(), "get_queue_info returned {:?}", result3);
}

#[test]
Expand Down

0 comments on commit 858d844

Please sign in to comment.