dramatiq

dramatiq copied to clipboard

RabbitMQ broker doesn't seem to retry publishing on SSL socket errors

2

# Issues GitHub issues are for bugs. If you have questions, please ask them on the [discussion board](https://reddit.com/r/dramatiq). ## Checklist * [x] Does your title concisely summarize the problem? *...

shshe

## What OS are you using? Ubuntu 22.04 ## What version of Dramatiq are you using? 1.15.0 ## What did you do? Processing parallel async messages using Dramatiq ## What...

dvazar

Dramatiq workers hangs very often, no logs were seen in logs even if it is verbose mode.

5

# Issues GitHub issues are for bugs. If you have questions, please ask them on the [mailing list](https://groups.io/g/dramatiq-users/topics). ## Checklist * [x] Does your title concisely summarize the problem? *...

Harinib-Kore

Document asyncio support

4

Need add full examples and info about ASYNCIO in dramatiq

ArtemIsmagilov

Mark message as failed when fail to process

1

Mark message as `failed` when actor raises an Exception. On `self.consumers[message.queue_name].post_process_message(message)` the method `nack` will be called. This change will enable refactor on `dramatiq_sqs` to skip message delete and redrive...

jairhenrique

## What OS are you using? OS not related ## What version of Dramatiq are you using? 1.14.1 ## What did you do? I used example from https://dramatiq.io/cookbook.html#scheduling-messages: ``` import...

maciejpolanczyk

OSError: [Errno 98] Address already in use when calling send function

9

# Issues GitHub issues are for bugs. If you have questions, please ask them on the [mailing list](https://groups.io/g/dramatiq-users/topics). ## Checklist * [x] Does your title concisely summarize the problem? *...

heatherKoo07

why not aio-pika?

2

Your code use sync pika. Does it make sense to use aio-pika https://github.com/mosquito/aio-pika ?

ArtemIsmagilov

Discussion: Resque-like priority queues

1

# Situation The default behavior of Dramatiq when multiple queues are present (either all of them or a subset), is to fetch data from them using the consumer threads. This...

h3nnn4n

fix: detect the missing of rabbitmq queue and redeclare it.

11

The declared rabbitmq queue will be missing sometime, such as deletion by mistake or rabbitmq server failure. So I add some logic to make sure the missing queue to be...

JetDrag