Merge pull request #4 from Superbalist/max-messages

Add max messages config setting to google adapter

Author: Bertus Steenberg

src/PubSubConnectionFactory.php

@@ -126,6 +126,7 @@ protected function makeGoogleCloudAdapter(array $config)
         $autoCreateSubscriptions = array_get($config, 'auto_create_subscriptions', true);
         $backgroundBatching = array_get($config, 'background_batching', false);
         $backgroundDaemon = array_get($config, 'background_daemon', false);
+        $maxMessages = array_get($config, 'max_messages', 1000);
 
         if ($backgroundDaemon) {
             putenv('IS_BATCH_DAEMON_RUNNING=true');
@@ -136,7 +137,8 @@ protected function makeGoogleCloudAdapter(array $config)
             $clientIdentifier,
             $autoCreateTopics,
             $autoCreateSubscriptions,
-            $backgroundBatching
+            $backgroundBatching,
+            $maxMessages
         );
     }
 

src/config/config.php

@@ -62,6 +62,7 @@
             'auth_cache' => null, // eg: \Google\Auth\Cache\MemoryCacheItemPool::class,
             'background_batching' => false,
             'background_daemon' => false,
+            'max_messages' => 1000,
         ],
 
         'http' => [