Supporting Enqueue
Enqueue is an MIT-licensed open source project with its ongoing development made possible entirely by the support of community and our customers. If you’d like to join them, please consider:
Google Pub Sub transport
A transport for Google Pub Sub cloud MQ. It uses internally official google sdk library google/cloud-pubsub
Installation
$ composer require enqueue/gps
Create context
To enable the Google Cloud Pub/Sub Emulator, set the PUBSUB_EMULATOR_HOST environment variable. There is a handy docker container google/cloud-sdk.
<?php
use Enqueue\Gps\GpsConnectionFactory;
putenv('PUBSUB_EMULATOR_HOST=http://localhost:8900');
$connectionFactory = new GpsConnectionFactory();
// save as above
$connectionFactory = new GpsConnectionFactory('gps:');
$context = $connectionFactory->createContext();
// if you have enqueue/enqueue library installed you can use a factory to build context from DSN
$context = (new \Enqueue\ConnectionFactoryFactory())->create('gps:')->createContext();
Send message to topic
Before you can send message you have to declare a topic. The operation creates a topic on a broker side. Google allows messages to be sent only to topic.
<?php
/** @var \Enqueue\Gps\GpsContext $context */
$fooTopic = $context->createTopic('foo');
$message = $context->createMessage('Hello world!');
$context->declareTopic($fooTopic);
$context->createProducer()->send($fooTopic, $message);
Consume message:
Before you can consume message you have to subscribe a queue to the topic. Google does not allow consuming message from the topic directly.
<?php
/** @var \Enqueue\Gps\GpsContext $context */
$fooTopic = $context->createTopic('foo');
$fooQueue = $context->createQueue('foo');
$context->subscribe($fooTopic, $fooQueue);
$consumer = $context->createConsumer($fooQueue);
$message = $consumer->receive();
// process a message
$consumer->acknowledge($message);
// $consumer->reject($message);