Google Cloud Platform pub/sub PHP example

composer.json

{
    "require": {
        "google/cloud-pubsub": "^0.12.0"
    }
}

publisher.php

<?php

require 'vendor/autoload.php';

use Google\Cloud\PubSub\PubSubClient;

$pubSub = new PubSubClient([
    'projectId' => 'my_project'
]);

$topic = $pubSub->topic('my_topic');
if (!$topic->exists()) {
  $pubSub->createTopic('my_topic');
}

// Publish a message to the topic.
$topic->publish([
    'data' => 'My new message.',
    'attributes' => [
        'location' => 'Detroit'
    ]
]);

subscriber.php

<?php

require 'vendor/autoload.php';

use Google\Cloud\PubSub\PubSubClient;

$pubSub = new PubSubClient([
    'projectId' => 'my_project'
]);

$subscription = $pubSub->subscription('my_subscription');
if (!$subscription->exists()) {
    $pubSub->subscribe('my_subscription', 'my_topic');
}

// TODO: listen for SIGTERM and SIGKILL and stop the loop
while (true) {
    $messages = $subscription->pull();

    foreach ($messages as $message) {
        echo '>> New message, received at ', date('Y-m-d H:i:s'), "\n";
        echo 'Data: ', $message->data() , "\n";
        echo 'Location: ', $message->attribute('location'), "\n\n";

        $subscription->acknowledge($message);
    }
}

This setup is only meant for pull. For push, please follow the examples provided by google itself.