enqueue-dev

enqueue-dev copied to clipboard

Symfony RPC

1

Hi, I have a problem with replay feedback. Producer creates a temporary queue and sends a message to it. Unfortunately, the consumer cannot read it and does not return any...

tkowalski29

[rdkafka] RdKafka transport does not support merging for `global` configuration

6

Considering: ``` # config/packages/enqueue.yaml enqueue: default: transport: dsn: "rdkafka://" global: bootstrap.servers: '%env(KAFKA_BOOTSTRAP_SERVERS)%' security.protocol: ssl group.id: '%env(KAFKA_GROUP_ID)%' ssl.ca.location: '%env(KAFKA_ROOT_CA)%' ssl.certificate.location: '%env(KAFKA_CERT)%' ssl.key.location: '%env(KAFKA_KEY)%' enable.ssl.certificate.verification: 'false' ssl.endpoint.identification.algorithm: 'none' enable.auto.commit: 'true' topic: auto.offset.reset:...

Wirone

User Deprecated: Method "Interop\Queue\Processor::process()" might add "string|object" as a native return type declaration in the future. Do the same in implementation "Enqueue\Client\DelegateProcessor" now to avoid errors or add an explicit...

dannyvw

doctrine/dbal:3.* dependency issue

1

Hi "enqueue/job-queue" and "enqueue/dbal" have different requirements for "doctrine/dbal". Following is what composer gives: - enqueue/job-queue 0.10.16 requires doctrine/dbal ^2.12 - enqueue/dbal 0.10.17 requires doctrine/dbal ^2.12|^3.1 Is it possible to...

galiganu

When the running time is greater than 8 hours, Throw a Error:General error: 2006 MySQL server has gone away

1

When the running time is greater than 8 hours,The php-enqueue throw a Error:"General error: 2006 MySQL server has gone away." Is there any solution? 

jsonhet

refactor(namespaces): renamed \Null to \NoEffect for future comp…

15

…atibility with new PHP versions 'null' is a reserved keyword as of PHP version 7.0 and should not be used to name a class, interface or trait or as part...

norbertws

snapshotpl

Use onPostConsume Hook for Calculating Messages Consumed

1

Fixes issue where no messages are consumed if value is set to 1. The first messages will be received and processing will stop.

amayer5125

[BUG] Declaration of Enqueue\Container\Container::has

3

Is the error with run command ` PHP Fatal error: Declaration of Enqueue\Container\Container::has($id) must be compatible with Psr\Container\ContainerInterface::has(string $id): bool in /var/www/html/wp-content/plugins/visualinmueble/vendor/enqueue/enqueue/Container/Container.php on line 28`

FuriosoJack

non-static QueueSubscriberInterface::getSubscribedQueues()

1

I propose to make this accessor non-static to allow developers build more flexible mechanism of subscription. For example I have code: ```php abstract class AbstractConsumer implements Processor, QueueSubscriberInterface { //...

andreyserdjuk