1 files changed, 0 insertions, 38 deletions
diff --git a/src/main/scala/xyz/driver/common/concurrent/InMemoryBridgeUploadQueue.scala b/src/main/scala/xyz/driver/common/concurrent/InMemoryBridgeUploadQueue.scala
deleted file mode 100644
index b19be42..0000000
--- a/src/main/scala/xyz/driver/common/concurrent/InMemoryBridgeUploadQueue.scala
+++ /dev/null
@@ -1,38 +0,0 @@
-package xyz.driver.common.concurrent
-
-import java.util.concurrent.LinkedBlockingQueue
-
-import xyz.driver.common.concurrent.BridgeUploadQueue.Item
-import xyz.driver.common.domain.LongId
-import xyz.driver.common.logging.PhiLogging
-
-import scala.collection.JavaConverters._
-import scala.concurrent.Future
-
-/**
-  * Use it only for tests
-  */
-class InMemoryBridgeUploadQueue extends BridgeUploadQueue with PhiLogging {
-
-  private val queue = new LinkedBlockingQueue[Item]()
-
-  override def add(item: Item): Future[Unit] = {
-    queue.add(item)
-    done
-  }
-
-  override def tryRetry(item: Item): Future[Option[Item]] = Future.successful(Some(item))
-
-  override def get(kind: String): Future[Option[Item]] = {
-    val r = queue.iterator().asScala.find(_.kind == kind)
-    Future.successful(r)
-  }
-
-  override def remove(item: LongId[Item]): Future[Unit] = {
-    queue.remove(item)
-    done
-  }
-
-  private val done = Future.successful(())
-
-}