rele icon indicating copy to clipboard operation
rele copied to clipboard

Easy to use Google Pub/Sub

Results 33 rele issues
Sort by recently updated
recently updated
newest added

Looking through the documentation and the code, this library creates a new subscription on the PubSub topic specified in the `sub` decorator. I'm looking to separate code that creates infrastructure...

### :tophat: What? allow create a subscriber with dead-lettering & exponential retries ### :thinking: Why? we need a way to configure those 2 parameters programmatically ### :link: Related issue Fix...

For now, there's no way to pass other args to the subscriber [request](https://github.com/mercadona/rele/blob/master/rele/client.py#L79-L83); when creating a subscriber, would you consider introducing this feature by either defining the `dead_letter_policy ` and...

Hello, would you consider introducing Avro encoder support for the publisher?

Log message payload in `post_process_message_success`. Now we have the `post_process_message_failure` and `post_publish_failure` logging the gcloud Message, we are also changing that to only log the message payload. The gcloud library...

### :tophat: What? Ignore subscriptions that do not define a topic name. ### :thinking: Why? Autodiscovery support for class-based Subscriptions (https://github.com/mercadona/rele/issues/161) opens the possibility to create generic classes with shared...

After #202 is implemented, for 2.0 we can switch to synchronous publishing, since that is the most sane, less surprising default and you can easily set `blocking=False` if you so...

enhancement

Ability to set `blocking=True|False` globally for a project. In many cases it is desirable to default to `True`. For example, a cron job or a worker may finish before actual...

enhancement

It would be nice to track the exceptions which happen when it is not possible to publish a message, for example, when there is a connectivity problem. At the moment,...

enhancement

It would be useful to explicitly retry a message without the need of raising an exception. We currently have this behaviour: ``` try: res = self._subscription(data, **dict(message.attributes)) except Exception as...