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 /src/main/scala/xyz/driver/core/pubsub.scala | |
parent | 5013a7fde52e4459c12ff5e92793cad9fc2f23db (diff) | |
download | driver-core-ebab5c30abf29d72d0b09dc519a493396e4e9e69.tar.gz driver-core-ebab5c30abf29d72d0b09dc519a493396e4e9e69.tar.bz2 driver-core-ebab5c30abf29d72d0b09dc519a493396e4e9e69.zip |
Google pubsub util
Diffstat (limited to 'src/main/scala/xyz/driver/core/pubsub.scala')
-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) |