Skip to content

Commit 10acfe0

Browse files
Fix a test
1 parent 0b72ed5 commit 10acfe0

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

tests/unit_cluster_definition_set_transformations_tests.rs

+4-2
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ mod test_helpers;
1515

1616
use rabbitmq_http_client::commons::{QueueType, X_ARGUMENT_KEY_X_QUEUE_TYPE};
1717
use rabbitmq_http_client::responses::{ClusterDefinitionSet, PolicyDefinitionOps};
18-
use rabbitmq_http_client::transformers::TransformationChain;
18+
use rabbitmq_http_client::transformers::{StripCmqKeysFromPolicies, TransformationChain};
1919
use serde_json::json;
2020

2121
#[test]
@@ -228,7 +228,9 @@ fn test_unit_strip_cmq_policies_case1() {
228228
assert_eq!(4, p0.definition.len());
229229
assert_eq!(true, p0.definition.has_cmq_keys());
230230

231-
let chain = TransformationChain::from(vec!["strip_cmq_policies"]);
231+
let chain = TransformationChain {
232+
chain: vec![Box::new(StripCmqKeysFromPolicies::default())],
233+
};
232234
let defs1 = chain.apply(&mut defs0);
233235

234236
// Three CMQ-related queues were stripped

0 commit comments

Comments
 (0)