aio-pika

aio-pika copied to clipboard

Application developers should typically use the high-level asyncio functions, such as `asyncio.run()`, and should rarely need to reference the `loop` object or call its methods

Olegt0rr

How should I implement an asynchronous consumer with timeout

1

I have an architecture where there's an allocation component watching rabbitmq queues and spawning worker processes to digest said queues. The workers spawn targeted at a specific queue and are...

mastern2k3

Incorrect processing of message

1

I think there is inconsistency of `IncomingMessage.__processed` flag with the state at the server side. Here is the processing within `IncomingMessage.ack` method: https://github.com/mosquito/aio-pika/blob/d65c2f4551b4fd75e4e15443042d716b3ac68c3c/aio_pika/message.py#L544-L552 If there was an error in `basic_ack`...

decaz

python 3.12 compatibility

4

hey it looks like that aio-pika is not compatible with python 3.12 and i haven't found an issue yet. i think it is the same as described here https://github.com/aio-libs/aiohttp/issues/7739

Loki-Afro

aio-pika==9.4.0 aiormq== 6.8.0 RabbitMQ==3.12.9, remote cluster Related issues: https://github.com/mosquito/aio-pika/issues/588 https://github.com/mosquito/aio-pika/issues/577 https://github.com/mosquito/aio-pika/issues/563 After period of inactivity we observed an error in logs: __reader:668 Server connection was stuck. No frames were received...

lin-goo

ChannelInvalidStateError after updating secret and publishing a message

1

Hi, I'm using the RabbitMQ OAuth 2.0 authentication backend, and therefore connecting to the broker with access tokens. These tokens can expire, so I have a wrapper around the publishing...

sidjakinsboriss

Updating credentials not possible in initial connection loop of robust connection

6

We are using the robust connection of aio-pika to connect to our AMQP broker using an OAuth2 token as the AMQP password which was retrieved beforehand. However we are running...

MatthiasWerning

Do not use deprecated datetime.utcnow and datetime.utcfromtimestamp

3

This change can be breaking because timestamp of incoming message will now have timezone info (UTC by default). Fixes #609.

decaz

Publishing Message - NOT_IMPLEMENTED - immediate=true

1

Hey there, When trying to use the `immediate` flag when publishing a message I seem to be getting an error: `NOT_IMPLEMENTED - immediate=true` Is the immediate flag indeed not implemented...

Friendliness

Consumer gets stuck on ack

4

I'm trying to run a consumer in a docker swarm cluster. The app consumes multiple events from a queue, writes them as bulk a database and then afterwards acknowledges them...

kimdre