diff options
author | vlad <vlad@driver.xyz> | 2017-06-13 16:15:07 -0700 |
---|---|---|
committer | vlad <vlad@driver.xyz> | 2017-06-13 16:15:07 -0700 |
commit | 91a4120b4253dc4a1e9552ec39fcb25c303a21e1 (patch) | |
tree | 9173797ed8e3d780f98ac8d0f85507eeb10c8016 /src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala | |
parent | cd1b635b2ae90d9ac2d8b1779183a1fbd8c5fd5c (diff) | |
download | rest-query-91a4120b4253dc4a1e9552ec39fcb25c303a21e1.tar.gz rest-query-91a4120b4253dc4a1e9552ec39fcb25c303a21e1.tar.bz2 rest-query-91a4120b4253dc4a1e9552ec39fcb25c303a21e1.zip |
Diffstat (limited to 'src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala')
-rw-r--r-- | src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala b/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala index 8c87b60..a98d2cd 100644 --- a/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala +++ b/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala @@ -30,8 +30,9 @@ object BridgeUploadQueueRepositoryAdapter { */ final case class LimitExponential(startInterval: FiniteDuration, intervalFactor: Double, - maxInterval: FiniteDuration, - onComplete: OnComplete) extends Strategy { + maxInterval: FiniteDuration, + onComplete: OnComplete) + extends Strategy { override def on(attempt: Int): OnAttempt = { OnAttempt.Continue(intervalFor(attempt).min(maxInterval)) @@ -67,14 +68,14 @@ object BridgeUploadQueueRepositoryAdapter { sealed trait OnComplete object OnComplete { case object Delete extends OnComplete - case object Mark extends OnComplete + case object Mark extends OnComplete implicit def toPhiString(x: OnAttempt): PhiString = Unsafe(x.toString) } sealed trait OnAttempt object OnAttempt { - case object Complete extends OnAttempt + case object Complete extends OnAttempt case class Continue(interval: Duration) extends OnAttempt implicit def toPhiString(x: OnAttempt): PhiString = Unsafe(x.toString) @@ -84,9 +85,8 @@ object BridgeUploadQueueRepositoryAdapter { class BridgeUploadQueueRepositoryAdapter(strategy: Strategy, repository: BridgeUploadQueueRepository, - transactions: Transactions) - (implicit executionContext: ExecutionContext) - extends BridgeUploadQueue with PhiLogging { + transactions: Transactions)(implicit executionContext: ExecutionContext) + extends BridgeUploadQueue with PhiLogging { override def add(item: Item): Future[Unit] = transactions.run { _ => repository.add(item) @@ -104,7 +104,7 @@ class BridgeUploadQueueRepositoryAdapter(strategy: Strategy, case Mark => repository.getById(item) match { case Some(x) => repository.update(x.copy(completed = true)) - case None => throw new RuntimeException(s"Can not find the $item task") + case None => throw new RuntimeException(s"Can not find the $item task") } } } @@ -115,7 +115,7 @@ class BridgeUploadQueueRepositoryAdapter(strategy: Strategy, logger.trace(phi"tryRetry($item)") val newAttempts = item.attempts + 1 - val action = strategy.on(newAttempts) + val action = strategy.on(newAttempts) logger.debug(phi"Action for ${Unsafe(newAttempts)}: $action") action match { |