Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: direct call to create cloud task for delayed messages #8

Closed
wants to merge 24 commits into from

Conversation

sauravcld
Copy link

No description provided.

sauravcld and others added 24 commits November 18, 2020 18:56
- add gcp pubsub support
    - add custom Transport
    - add custom Message
    - add custom Channel
- fix gcp pubsub connection
- add basic publish
- add basic exchange
- create subscription
- basic consume
- basic ack
- basic consume
- basic ack

todo:

- fix multiconsume
- add docstring
- remove unused code
- fix multiple consume
- fix qos basic_ack inheritence
    1. Updated requirement files
    2. Test case for channel class
1. raise exception when no get
2. refactored unit tests
- ignore pull from pidbox related queues
- increases consumer throughput
@sauravcld sauravcld closed this Dec 16, 2020
mpsmks pushed a commit that referenced this pull request Dec 18, 2020
fix: service account email to be fetched from celery app config
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants