Cassandra com.datastax.driver.core.ControlConnection $ 1 onConnectionException - PullRequest
Новая
       29

Cassandra com.datastax.driver.core.ControlConnection $ 1 onConnectionException

0 голосов
/ 11 января 2019

Я использую Кассандра 3.11.3 с Лагом 1.4.7 . Я написал интеграционные тесты для Impl, но столкнулся с исключением ControlConnection. Это тестовый файл ниже: 

 class BookingServiceImplIntegrationTest extends AsyncWordSpec with Matchers with BeforeAndAfterAll {

  private val server = ServiceTest.startServer(ServiceTest.defaultSetup.withCassandra(true)) { ctx =>
    new BookingApplication(ctx) with LocalServiceLocator {
      override def additionalConfiguration: AdditionalConfiguration =
        super.additionalConfiguration ++ Configuration.from(Map(
          "cassandra-query-journal.eventual-consistency-delay" -> "0"
        ))
    }
  }

  val bookingService: BookingService = server.serviceClient.implement[BookingService]

  import server.materializer

  override def afterAll: Unit = server.stop()

  "The Booking service" should {

    "allow add bookings" in {
      for {
        created <- addBooking(BookingDetails)
        retrieved <- retrieveBookings(created)
      } yield {
        created should ===(retrieved)
      }
    }
  }

  def awaitSuccess[T](maxDuration: FiniteDuration = 10.seconds, checkEvery: FiniteDuration = 100.milliseconds)(block: => Future[T]): Future[T] = {
    val checkUntil = System.currentTimeMillis() + maxDuration.toMillis

    def doCheck(): Future[T] = {
      block.recoverWith {
        case recheck if checkUntil > System.currentTimeMillis() =>
          val timeout = Promise[T]()
          server.application.actorSystem.scheduler.scheduleOnce(checkEvery) {
            timeout.completeWith(doCheck())
          }(server.executionContext)
          timeout.future
      }
    }

    doCheck()
  }

При запуске этого тестового файла я сталкиваюсь с исключением: enter image description here

Пожалуйста, предложите, как решить это !! Заранее спасибо

...