diff options
| author | vlad <vlad@driver.xyz> | 2017-06-29 20:36:49 -0700 |
|---|---|---|
| committer | vlad <vlad@driver.xyz> | 2017-06-29 20:36:49 -0700 |
| commit | ebab5c30abf29d72d0b09dc519a493396e4e9e69 (patch) | |
| tree | 0571192e0f76ddb2202eba18ddaae5e9da91046f | |
| parent | 5013a7fde52e4459c12ff5e92793cad9fc2f23db (diff) | |
| download | driver-core-ebab5c30abf29d72d0b09dc519a493396e4e9e69.tar.gz driver-core-ebab5c30abf29d72d0b09dc519a493396e4e9e69.tar.bz2 driver-core-ebab5c30abf29d72d0b09dc519a493396e4e9e69.zip | |
Google pubsub util
| -rw-r--r-- | src/main/scala/xyz/driver/core/pubsub.scala | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/main/scala/xyz/driver/core/pubsub.scala b/src/main/scala/xyz/driver/core/pubsub.scala index 4853c35..ee84328 100644 --- a/src/main/scala/xyz/driver/core/pubsub.scala +++ b/src/main/scala/xyz/driver/core/pubsub.scala @@ -59,9 +59,11 @@ object pubsub { def stopListening(): Unit } - class GooglePubsubSubscriber[T](projectId: String, subscriptionId: String, receiver: String => Future[T], log: Logger)( - implicit ex: ExecutionContext) - extends PubsubSubscriber { + class GooglePubsubSubscriber[T](projectId: String, + subscriptionId: String, + receiver: String => Future[T], + log: Logger)(implicit ex: ExecutionContext) + extends PubsubSubscriber { private val subscriptionName = SubscriptionName.create(projectId, subscriptionId) |