enqueue-dev

enqueue-dev copied to clipboard

[Suggestion] RabbitMQ Quorum queue support

3

Quorum queues are modern queues based on Raft consensus algorithm. It is available as of RabbitMQ 3.8.0. Classic mirrored queues are deprecated and will be removed in the future. This...

astronom

Since Redis 6.0 released on 2020 a float value is allowed to define the timeout for brpop commands: https://github.com/redis/redis/commit/eca0187370c14aa2c126fe07e5310e44c2780a95 https://redis.io/commands/brpop/ ``` Starting with Redis version 6.0.0: timeout is interpreted as...

renatogcarvalho

So I noticed lately that enqueue is sending messages through sync aws client. Which takes a bit of time and waits for full response which shouldn't really be necessary in...

wslawski-printify

Run CI tests in php 8.3 in CI

10

Hi, This PR allows to run the CI on php 8.3

amenophis

Bugfix in `RdKafkaProducer:flush()` method

8

Avoid TypeError in `RdKafkaProducer::flush()`

alexbusu-motork

Update uuid DbalProducer.php

1

From this thread https://github.com/ramsey/uuid/issues/327 ramsey/uuid 4.1 introduced Ramsey\Uuid\Lazy\LazyUuidFromString object which is used over the original Ramsey\Uuid\Uuid object when generating Uuids (I.E. when using Uuid::uuid4()). This causes conversion issues when using...

KrisHarris

Lack of **beanstalkd** listening port (**11300**) in docker-compose.yml prevents run of tests (no connection) Adding of required port to docker-compose.yml solves this issue

g41797

Support Symfony 7

4

Opened this one in favor of #1326, #1328 and #1331. The goal is to unite the work of all other PRs and debug this until we have the awaited compatibility...

alexandre-daubois

> Expected type 'null|RdKafka\Message'. Found 'Interop\Queue\Message'. `intelephense(P1006)`

qkdreyer

When using the redis transport, RedisConsumer::processResult() creates the redelivered record prior to the RedisSubscription callback executing. The subscription callback attached with Enqueue\Consumption\QueueConsumer then invokes RedisConsumer::reject(). Calling acknowledge() here deletes the...

compwright