Skip to content

Commit

Permalink
cargo fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
@mkuratczyk
mkuratczyk committed Jun 6, 2023
1 parent 47f17c0 commit 3ce2cae
Show file tree
Hide file tree
Showing 4 changed files with 23 additions and 115 deletions.
60 changes: 10 additions & 50 deletions tests/binding_tests.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,37 +17,21 @@ fn test_list_all_bindings() {
let fanout = "amq.fanout";

let result1 = rc.declare_queue(vh_name, &QueueParams::new_durable_classic_queue(cq, None));
assert!(
result1.is_ok(),
"declare_queue returned {:?}",
result1
);
assert!(result1.is_ok(), "declare_queue returned {:?}", result1);

let result2 = rc.bind_queue(vh_name, cq, fanout, None, None);
assert!(
result2.is_ok(),
"bind_queue returned {:?}",
result2
);
assert!(result2.is_ok(), "bind_queue returned {:?}", result2);

let result3 = rc.list_bindings();
assert!(
result3.is_ok(),
"list_bindings returned {:?}",
result3
);
assert!(result3.is_ok(), "list_bindings returned {:?}", result3);
let vec = result3.unwrap();
assert!(vec
.iter()
.find(|b| b.destination == cq && b.source == fanout)
.is_some());

let result4 = rc.list_bindings_in(vh_name);
assert!(
result4.is_ok(),
"list_bindings_in returned {:?}",
result4
);
assert!(result4.is_ok(), "list_bindings_in returned {:?}", result4);
let vec = result4.unwrap();
assert!(vec
.iter()
Expand All @@ -67,18 +51,10 @@ fn test_list_only_queue_bindings() {
let fanout = "amq.fanout";

let result1 = rc.declare_queue(vh_name, &QueueParams::new_durable_classic_queue(cq, None));
assert!(
result1.is_ok(),
"declare_queue returned {:?}",
result1
);
assert!(result1.is_ok(), "declare_queue returned {:?}", result1);

let result2 = rc.bind_queue(vh_name, cq, fanout, None, None);
assert!(
result2.is_ok(),
"bind_queue returned {:?}",
result2
);
assert!(result2.is_ok(), "bind_queue returned {:?}", result2);

let result3 = rc.list_queue_bindings(vh_name, cq);
assert!(
Expand Down Expand Up @@ -112,32 +88,16 @@ fn test_list_only_exchange_bindings() {
vh_name,
&ExchangeParams::fanout(fanout2, false, false, None),
);
assert!(
result1.is_ok(),
"declare_exchange returned {:?}",
result1
);
assert!(result1.is_ok(), "declare_exchange returned {:?}", result1);

let result2 = rc.bind_exchange(vh_name, fanout1, fanout2, None, None);
assert!(
result2.is_ok(),
"bind_exchange returned {:?}",
result2
);
assert!(result2.is_ok(), "bind_exchange returned {:?}", result2);

let result3 = rc.declare_queue(vh_name, &QueueParams::new_durable_classic_queue(cq, None));
assert!(
result3.is_ok(),
"declare_queue returned {:?}",
result3
);
assert!(result3.is_ok(), "declare_queue returned {:?}", result3);

let result4 = rc.bind_queue(vh_name, cq, fanout1, None, None);
assert!(
result4.is_ok(),
"bind_queue returned {:?}",
result4
);
assert!(result4.is_ok(), "bind_queue returned {:?}", result4);

let result5 = rc.list_exchange_bindings_with_source(vh_name, fanout2);
assert!(
Expand Down
6 changes: 1 addition & 5 deletions tests/connection_tests.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,11 +9,7 @@ fn test_list_connections() {
let rc = Client::new_with_basic_auth_credentials(&endpoint, USERNAME, PASSWORD);

let result1 = rc.list_connections();
assert!(
result1.is_ok(),
"list_connections returned {:?}",
result1
);
assert!(result1.is_ok(), "list_connections returned {:?}", result1);
}

#[test]
Expand Down
6 changes: 1 addition & 5 deletions tests/policy_tests.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -80,11 +80,7 @@ fn test_a_policy(rc: &Client, policy: &PolicyParams) {
assert!(policies.iter().find(|p| p.name == policy.name).is_none());

let result = rc.declare_policy(&policy);
assert!(
result.is_ok(),
"declare_policy returned {:?}",
result
);
assert!(result.is_ok(), "declare_policy returned {:?}", result);

// validate it was created as expected
let result = rc.get_policy(policy.vhost, policy.name);
Expand Down
66 changes: 11 additions & 55 deletions tests/queue_tests.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -14,22 +14,14 @@ 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(), "get_queue_info returned {:?}", result1);

let mut map = Map::<String, Value>::new();
map.insert("x-max-length".to_owned(), json!(10_000));
let optional_args = Some(map);
let params = QueueParams::new_quorum_queue(&name, optional_args);
let result2 = rc.declare_queue(&vhost, &params);
assert!(
result2.is_ok(),
"declare_queue returned {:?}",
result2
);
assert!(result2.is_ok(), "declare_queue returned {:?}", result2);

let _ = rc.delete_queue(&vhost, &name);
}
Expand All @@ -44,22 +36,14 @@ 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(), "get_queue_info returned {:?}", result1);

let mut map = Map::<String, Value>::new();
map.insert("x-max-length-bytes".to_owned(), json!(10_000_000));
let optional_args = Some(map);
let params = QueueParams::new_stream(&name, optional_args);
let result2 = rc.declare_queue(&vhost, &params);
assert!(
result2.is_ok(),
"declare_queue returned {:?}",
result2
);
assert!(result2.is_ok(), "declare_queue returned {:?}", result2);

let _ = rc.delete_queue(&vhost, &name);
}
Expand All @@ -74,29 +58,17 @@ 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(), "get_queue_info returned {:?}", result1);

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
);
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
);
assert!(result3.is_ok(), "get_queue_info returned {:?}", result3);
}

#[test]
Expand All @@ -108,20 +80,12 @@ fn test_list_all_queues() {

let params = QueueParams::new_exclusive_classic_queue("rust.tests.cq.exclusive.23487866", None);
let result1 = rc.declare_queue(vh_name, &params);
assert!(
result1.is_ok(),
"declare_queue returned {:?}",
result1
);
assert!(result1.is_ok(), "declare_queue returned {:?}", result1);

common::await_queue_metric_emission();

let result2 = rc.list_queues();
assert!(
result2.is_ok(),
"list_queues returned {:?}",
result2
);
assert!(result2.is_ok(), "list_queues returned {:?}", result2);
}

#[test]
Expand All @@ -134,18 +98,10 @@ fn test_list_queues_in_a_virtual_host() {
let params =
QueueParams::new_exclusive_classic_queue("rust.tests.cq.exclusive.64692734867", None);
let result1 = rc.declare_queue(vh_name, &params);
assert!(
result1.is_ok(),
"declare_queue returned {:?}",
result1
);
assert!(result1.is_ok(), "declare_queue returned {:?}", result1);

common::await_queue_metric_emission();

let result2 = rc.list_queues_in(vh_name);
assert!(
result2.is_ok(),
"list_queues_in returned {:?}",
result2
);
assert!(result2.is_ok(), "list_queues_in returned {:?}", result2);
}

0 comments on commit 3ce2cae

Please sign in to comment.