amqp_transport.md

AMQP transport

Implements AMQP specifications. Build on top of php amqp extension.

• Create context
• Declare topic
• Declare queue
• Bind queue to topic
• Send message to topic
• Send message to queue
• Consume message
• Purge queue messages

Create context

<?php
use Enqueue\AmqpExt\AmqpConnectionFactory;

$connectionFactory = new AmqpConnectionFactory([
    'host' => '127.0.0.1',
    'port' => 5672,
    'vhost' => '/',
    'login' => 'guest',
    'password' => 'guest',
    'persisted' => false,
]);

$psrContext = $connectionFactory->createContext();

Declare topic.

Declare topic operation creates a topic on a broker side.

<?php
/** @var \Enqueue\AmqpExt\AmqpContext $psrContext */

$fooTopic = $psrContext->createTopic('foo');
$fooTopic->addFlag(AMQP_EX_TYPE_FANOUT);
$psrContext->declareTopic($fooTopic);

// to remove topic use delete topic method
//$psrContext->deleteTopic($fooTopic);

Declare queue.

Declare queue operation creates a queue on a broker side.

<?php
/** @var \Enqueue\AmqpExt\AmqpContext $psrContext */

$fooQueue = $psrContext->createQueue('foo');
$fooQueue->addFlag(AMQP_DURABLE);
$psrContext->declareQueue($fooQueue);

// to remove topic use delete queue method
//$psrContext->deleteQueue($fooQueue);

Bind queue to topic

Connects a queue to the topic. So messages from that topic comes to the queue and could be processed.

<?php
/** @var \Enqueue\AmqpExt\AmqpContext $psrContext */
/** @var \Enqueue\AmqpExt\AmqpQueue $fooQueue */
/** @var \Enqueue\AmqpExt\AmqpTopic $fooTopic */

$psrContext->bind($fooTopic, $fooQueue);

Send message to topic

<?php
/** @var \Enqueue\AmqpExt\AmqpContext $psrContext */
/** @var \Enqueue\AmqpExt\AmqpTopic $fooTopic */

$message = $psrContext->createMessage('Hello world!');

$psrContext->createProducer()->send($fooTopic, $message);

Send message to queue

<?php
/** @var \Enqueue\AmqpExt\AmqpContext $psrContext */
/** @var \Enqueue\AmqpExt\AmqpQueue $fooQueue */

$message = $psrContext->createMessage('Hello world!');

$psrContext->createProducer()->send($fooQueue, $message);

Consume message:

<?php
/** @var \Enqueue\AmqpExt\AmqpContext $psrContext */
/** @var \Enqueue\AmqpExt\AmqpQueue $fooQueue */

$consumer = $psrContext->createConsumer($fooQueue);

$message = $consumer->receive();

// process a message

$consumer->acknowledge($message);
// $consumer->reject($message);

Purge queue messages:

<?php
/** @var \Enqueue\AmqpExt\AmqpContext $psrContext */
/** @var \Enqueue\AmqpExt\AmqpQueue $fooQueue */

$queue = $psrContext->createQueue('aQueue');

$psrContext->purge($queue);

back to index