forked from php-amqplib/RabbitMqBundle
-
Notifications
You must be signed in to change notification settings - Fork 47
Open
Labels
Description
Having following configuration:
rabbitmq:
consumers:
singlejob:
queue: { name: 'singlejob', passive: true }
callback: [ @App\Consumer\SingleJobConsumer, process ]
multipleJob:
queues:
multiplejob.low:
passive: true
callback: [ @App\Consumer\MultipleJobConsumer, process ]
multiplejob.high:
passive: true
callback: [ @App\Consumer\MultipleJobConsumer, process ]
Everything works for single job - it dies after 1 message is processed:
php index.php rabbitmq:consumer -m 1 singleJob
When testing multiplejobs - the process never dies and still consumes incoming messages:
php index.php rabbitmq:consumer -m 1 multipleJob
Reactions are currently unavailable