Skip to content

Commit

Permalink
Reimplemented Google Pub/Sub using their new SDK (#14)
Browse files Browse the repository at this point in the history
* Updated pubsub dependency to the new version

* Changed GooglePubSubProvider to use the new Google SDK

* Now creates both topic and subscription at the same time so messages don't get lost if producer starts before consumer

* Added ACK deadline config option

* Removed blank line

* Removed extra log message

* Fixed subscription options when creating the topic at the same time

* json_decode now returns objects rather than arrays for consistency with the AMQP provider

* getClient is now private
  • Loading branch information
rgooding committed Jun 19, 2018
1 parent 1dc879d commit 53d3d88
Show file tree
Hide file tree
Showing 2 changed files with 262 additions and 280 deletions.
4 changes: 2 additions & 2 deletions composer.json
Original file line number Diff line number Diff line change
Expand Up @@ -17,12 +17,12 @@
},
"suggest": {
"php-amqplib/php-amqplib": "Enables using queues in RabbitMQ",
"google/apiclient": "Enables using queues in Google PubSub"
"google/cloud-pubsub": "Enables using queues in Google Cloud PubSub"
},
"require-dev": {
"phpunit/phpunit": "~4.8.0",
"php-amqplib/php-amqplib": "~2.6.2",
"google/apiclient": "~1.0"
"google/cloud-pubsub": "~1.3.0"
},
"autoload": {
"psr-4": {
Expand Down
Loading

0 comments on commit 53d3d88

Please sign in to comment.