Pubsub final #11
Open
Pubsub final #11
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
- 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
Pubsub support for Kombu
Fix: message attributes to be set in pubsub Message declaration
feat: Support for `delay` task in Celery
feat: direct call to create cloud task for delayed messages
Support for delayed functions
Pubsub support for kombu
Added dependencies
Dependencies added
Development
feat: flag to support switch between sync and concurrent pulls
feat: flag to support switch between sync and concurrent pulls
fix: service account email to be fetched from celery app config
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
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
No description provided.