amqp_interop_basic_consume.php

amqp_interop_basic_consume.php

<?php

use Enqueue\AmqpExt\AmqpConnectionFactory;
use Interop\Amqp\AmqpConsumer;
use Interop\Amqp\AmqpMessage;

include __DIR__.'/vendor/autoload.php';

$context = (new AmqpConnectionFactory())->createContext();

$fooConsumer = $context->createConsumer(
    $context->createQueue('foo')
);

$barConsumer = $context->createConsumer(
    $context->createQueue('foo')
);

$context->subscribe($fooConsumer, function(AmqpMessage $message, AmqpConsumer $consumer) {
    // do something when a message from foo queue arrives.
    
    $consumer->acknowledge($message);
    
    return true;
});

$context->subscribe($barConsumer, function(AmqpMessage $message, AmqpConsumer $consumer) {
    // do something when a message from foo queue arrives.

    $consumer->acknowledge($message);

    return true;
});

$context->consume(); // blocks here

Both subscribe to "foo" queue, is that correct?

I guess it won't be as easy with the example you just gave. But if we can get an iterator instead of attaching the callback when during $context->subscribe(), then I guess we could use the MultipleIterator to combine generators as described in this StackOverflow question.