diff options
author | Jakob Odersky <jakob@driver.xyz> | 2017-11-19 23:29:03 -0800 |
---|---|---|
committer | Jakob Odersky <jakob@driver.xyz> | 2017-11-20 00:07:42 -0800 |
commit | b872ee2649c7b56df413fbde746ee68312c17abd (patch) | |
tree | 34b5fc63cc425a27969c73354fd7a2071ea67ba3 /src/main/scala/xyz/driver/core/pubsub.scala | |
parent | 871e25f5e5ba23ca9202009d49fb38386558edd9 (diff) | |
download | driver-core-b872ee2649c7b56df413fbde746ee68312c17abd.tar.gz driver-core-b872ee2649c7b56df413fbde746ee68312c17abd.tar.bz2 driver-core-b872ee2649c7b56df413fbde746ee68312c17abd.zip |
Apply new formatting
Diffstat (limited to 'src/main/scala/xyz/driver/core/pubsub.scala')
-rw-r--r-- | src/main/scala/xyz/driver/core/pubsub.scala | 27 |
1 files changed, 14 insertions, 13 deletions
diff --git a/src/main/scala/xyz/driver/core/pubsub.scala b/src/main/scala/xyz/driver/core/pubsub.scala index 7885c1f..149b0db 100644 --- a/src/main/scala/xyz/driver/core/pubsub.scala +++ b/src/main/scala/xyz/driver/core/pubsub.scala @@ -22,8 +22,8 @@ object pubsub { } class GooglePubsubPublisher[Message](projectId: String, topic: String, log: Logger, autoCreate: Boolean = true)( - implicit messageMarshaller: Marshaller[Message, String], - ex: ExecutionContext + implicit messageMarshaller: Marshaller[Message, String], + ex: ExecutionContext ) extends PubsubPublisher[Message] { type Result = Id[PubsubMessage] @@ -72,8 +72,8 @@ object pubsub { } class FakePubsubPublisher[Message](topicName: String, log: Logger)( - implicit messageMarshaller: Marshaller[Message, String], - ex: ExecutionContext) + implicit messageMarshaller: Marshaller[Message, String], + ex: ExecutionContext) extends PubsubPublisher[Message] { type Result = Id[PubsubMessage] @@ -91,11 +91,11 @@ object pubsub { } class GooglePubsubSubscriber[Message]( - projectId: String, - subscriptionId: String, - receiver: Message => Future[Unit], - log: Logger, - autoCreateSettings: Option[GooglePubsubSubscriber.SubscriptionSettings] = None + projectId: String, + subscriptionId: String, + receiver: Message => Future[Unit], + log: Logger, + autoCreateSettings: Option[GooglePubsubSubscriber.SubscriptionSettings] = None )(implicit messageMarshaller: Unmarshaller[String, Message], mat: Materializer, ex: ExecutionContext) extends PubsubSubscriber { @@ -117,10 +117,11 @@ object pubsub { val subscriptionExists = Try(adminClient.getSubscription(subscriptionName)).isSuccess if (!subscriptionExists) { val topicName = TopicName.create(projectId, subscriptionSettings.topic) - adminClient.createSubscription(subscriptionName, - topicName, - subscriptionSettings.pushConfig, - subscriptionSettings.ackDeadlineSeconds) + adminClient.createSubscription( + subscriptionName, + topicName, + subscriptionSettings.pushConfig, + subscriptionSettings.ackDeadlineSeconds) } } |