From ebab5c30abf29d72d0b09dc519a493396e4e9e69 Mon Sep 17 00:00:00 2001 From: vlad Date: Thu, 29 Jun 2017 20:36:49 -0700 Subject: Google pubsub util --- src/main/scala/xyz/driver/core/pubsub.scala | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) (limited to 'src/main') 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) -- cgit v1.2.3