From e8de3242a920e09445964c04fc47e804a1adbb1e Mon Sep 17 00:00:00 2001 From: Andrzej Ludwikowski Date: Mon, 16 Dec 2024 19:12:49 +0100 Subject: [PATCH] using objects --- .../main/scala/akka/javasdk/impl/consumer/ConsumerImpl.scala | 2 +- .../scala/akka/javasdk/impl/timedaction/TimedActionImpl.scala | 2 +- .../akka/javasdk/impl/timedaction/TimedActionImplSpec.scala | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/akka-javasdk/src/main/scala/akka/javasdk/impl/consumer/ConsumerImpl.scala b/akka-javasdk/src/main/scala/akka/javasdk/impl/consumer/ConsumerImpl.scala index 8cf40af6d..cd0a99032 100644 --- a/akka-javasdk/src/main/scala/akka/javasdk/impl/consumer/ConsumerImpl.scala +++ b/akka-javasdk/src/main/scala/akka/javasdk/impl/consumer/ConsumerImpl.scala @@ -112,7 +112,7 @@ private[impl] final class ConsumerImpl[C <: Consumer]( handleUnexpectedException(message, ex) } case IgnoreEffect => - Future.successful(new SpiConsumer.IgnoreEffect) + Future.successful(SpiConsumer.IgnoreEffect) case unknown => throw new IllegalArgumentException(s"Unknown TimedAction.Effect type ${unknown.getClass}") } diff --git a/akka-javasdk/src/main/scala/akka/javasdk/impl/timedaction/TimedActionImpl.scala b/akka-javasdk/src/main/scala/akka/javasdk/impl/timedaction/TimedActionImpl.scala index 8a35a2afe..a12624d4f 100644 --- a/akka-javasdk/src/main/scala/akka/javasdk/impl/timedaction/TimedActionImpl.scala +++ b/akka-javasdk/src/main/scala/akka/javasdk/impl/timedaction/TimedActionImpl.scala @@ -125,7 +125,7 @@ private[impl] final class TimedActionImpl[TA <: TimedAction]( private def toSpiEffect(command: Command, effect: TimedAction.Effect): Future[Effect] = { effect match { case ReplyEffect(_) => //FIXME remove meta, not used in the reply - Future.successful(new SpiTimedAction.SuccessEffect) + Future.successful(SpiTimedAction.SuccessEffect) case AsyncEffect(futureEffect) => futureEffect .flatMap { effect => toSpiEffect(command, effect) } diff --git a/akka-javasdk/src/test/scala/akka/javasdk/impl/timedaction/TimedActionImplSpec.scala b/akka-javasdk/src/test/scala/akka/javasdk/impl/timedaction/TimedActionImplSpec.scala index 1e4650bab..6c9daa327 100644 --- a/akka-javasdk/src/test/scala/akka/javasdk/impl/timedaction/TimedActionImplSpec.scala +++ b/akka-javasdk/src/test/scala/akka/javasdk/impl/timedaction/TimedActionImplSpec.scala @@ -87,7 +87,7 @@ class TimedActionImplSpec new SpiTimedAction.Command("MyMethod", Some(new BytesPayload(ByteString.empty, "")), SpiMetadata.empty)) .futureValue - reply shouldBe an[SpiTimedAction.SuccessEffect] + reply shouldBe an[SpiTimedAction.SuccessEffect.type] } "turn thrown command handler exceptions into failure responses" in {