~ubuntuone-hackers/kombu/trunk

Viewing all changes in revision 2338.

  • Committer: GitHub
  • Author(s): Gao
  • Date: 2022-03-15 14:21:07 UTC
  • Revision ID: git-v1:0282e1419fad98da5ae956ff38c7e87e539889ac
Add fanout to filesystem (#1499)

* Create a folder for each queue when using filesystem transport and add fanout support

* clean up unused variables

* Add fanout support to filesystem transport

filesystem transport lacks of fanout support.

1. Add fanout support to filesystem transport.
2. Add a unit test for it.

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

* Remove the refactoring work and make the test passed

1. Remove all of refactoring work
2. make the test pass

* Use pathlib for some Path operation

* Some reviewed changes

Co-authored-by: Yuriy Halytskyy <y.halytskyy@auckland.ac.nz>
Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>

expand all expand all

Show diffs side-by-side

added added

removed removed

Lines of Context: