bump up google/cloud requirement to ^0.11.0 and fix breaking changes implemented in lib

Author: matthewgoslett

composer.json

@@ -11,7 +11,7 @@
   "require": {
     "php": ">=5.6.0",
     "superbalist/php-pubsub": "^1.0",
-    "google/cloud": "^0.7.0|^0.8.0|^0.9.0|^0.10.0"
+    "google/cloud": "^0.11.0"
   },
   "autoload": {
     "psr-4": {

src/GoogleCloudPubSubAdapter.php

@@ -2,6 +2,7 @@
 
 namespace Superbalist\PubSub\GoogleCloud;
 
+use Google\Cloud\PubSub\Message;
 use Google\Cloud\PubSub\PubSubClient;
 use Superbalist\PubSub\PubSubAdapterInterface;
 use Superbalist\PubSub\Utils;
@@ -34,8 +35,12 @@ class GoogleCloudPubSubAdapter implements PubSubAdapterInterface
      * @param bool $autoCreateTopics
      * @param bool $autoCreateSubscriptions
      */
-    public function __construct(PubSubClient $client, $clientIdentifier = null, $autoCreateTopics = true, $autoCreateSubscriptions = true)
-    {
+    public function __construct(
+        PubSubClient $client,
+        $clientIdentifier = null,
+        $autoCreateTopics = true,
+        $autoCreateSubscriptions = true
+    ) {
         $this->client = $client;
         $this->clientIdentifier = $clientIdentifier;
         $this->autoCreateTopics = $autoCreateTopics;
@@ -134,17 +139,17 @@ public function subscribe($channel, callable $handler)
             $messages = $subscription->pull();
 
             foreach ($messages as $message) {
-                // the cloud library base64 encodes messages
-                $payload = base64_decode($message['message']['data']);
-                $payload = Utils::unserializeMessagePayload($payload);
+                /** @var Message $message */
+
+                $payload = Utils::unserializeMessagePayload($message->data());
 
                 if ($payload === 'unsubscribe') {
                     $isSubscriptionLoopActive = false;
                 } else {
                     call_user_func($handler, $payload);
                 }
 
-                $subscription->acknowledge($message['ackId']);
+                $subscription->acknowledge($message);
             }
         }
     }