diff --git a/example/src/main/resources/logback.xml b/example/src/main/resources/logback.xml index 34ec309..07ed72b 100644 --- a/example/src/main/resources/logback.xml +++ b/example/src/main/resources/logback.xml @@ -8,10 +8,11 @@ + - + \ No newline at end of file diff --git a/example/src/main/scala/endless/transaction/example/app/pekko/PekkoAccountsApp.scala b/example/src/main/scala/endless/transaction/example/app/pekko/PekkoAccountsApp.scala index 27f586b..96c5024 100644 --- a/example/src/main/scala/endless/transaction/example/app/pekko/PekkoAccountsApp.scala +++ b/example/src/main/scala/endless/transaction/example/app/pekko/PekkoAccountsApp.scala @@ -39,7 +39,7 @@ object PekkoAccountsApp { private implicit val transferParameters: TransferParameters = TransferParameters(timeout = 30.seconds) private implicit val askTimeout: Timeout = Timeout(30.seconds) - private val terminationTimeout = 30.seconds + private val terminationTimeout = 5.seconds private lazy val pekkoEventAdapter = new EventAdapter[AccountEvent, events.AccountEvent] { private val eventAdapter = new AccountEventAdapter override def toJournal(e: AccountEvent): events.AccountEvent = eventAdapter.toJournal(e) diff --git a/example/src/multi-jvm/scala/endless/transaction/example/StressSuite.scala b/example/src/multi-jvm/scala/endless/transaction/example/StressSuite.scala index 9ccf5bf..197d0aa 100644 --- a/example/src/multi-jvm/scala/endless/transaction/example/StressSuite.scala +++ b/example/src/multi-jvm/scala/endless/transaction/example/StressSuite.scala @@ -195,7 +195,7 @@ object Common { passiveNode(httpPort, arteryPort, checkSuccessful) .handleErrorWith((error: Throwable) => logger.error(error)("Node hard fail").toResource) .use_, - IO.sleep(restartPeriod) + IO.sleep(restartPeriod) >> logger.info("Time elapsed, shutting down...") ) _ <- checkSuccessful.get.flatMap { case true => logger.info("Balance check successful, terminating...")