diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-09-24 18:18:55 +0200 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-10-11 16:50:02 +0200 |
| commit | ecbd9698341406543efd195aff481c6704f6022b (patch) | |
| tree | 44a0c9e2b6ecdd8f9084e4853feadd0428e8a9db | |
| parent | 8ae60bef73da9acfdba37e60953f82c9fa5f47cc (diff) | |
| download | rabbitmq-server-git-ecbd9698341406543efd195aff481c6704f6022b.tar.gz | |
Embed RPC call function in test
| -rw-r--r-- | deps/rabbitmq_stream/test/commands_SUITE.erl | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/deps/rabbitmq_stream/test/commands_SUITE.erl b/deps/rabbitmq_stream/test/commands_SUITE.erl index c92acbd10c..42109a100b 100644 --- a/deps/rabbitmq_stream/test/commands_SUITE.erl +++ b/deps/rabbitmq_stream/test/commands_SUITE.erl @@ -415,8 +415,12 @@ add_delete_super_stream_run(Config) -> ok. -partitions(Config, SuperStream) -> - rabbit_stream_manager_SUITE:partitions(Config, SuperStream). +partitions(Config, Name) -> + rabbit_ct_broker_helpers:rpc(Config, + 0, + rabbit_stream_manager, + partitions, + [<<"/">>, Name]). create_stream(S, Stream, C0) -> rabbit_stream_SUITE:test_create_stream(gen_tcp, S, Stream, C0). |