From b89cc4c4172c55a1ec933449a24cf07cef6ba2df Mon Sep 17 00:00:00 2001 From: Renato Cavalcanti Date: Fri, 12 Jun 2020 21:27:27 +0200 Subject: [PATCH] User Interger in javadsl function --- .../sharding/typed/internal/ShardedDaemonProcessImpl.scala | 2 +- .../cluster/sharding/typed/javadsl/ShardedDaemonProcess.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/internal/ShardedDaemonProcessImpl.scala b/akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/internal/ShardedDaemonProcessImpl.scala index a5c12d66f1..3df856a276 100644 --- a/akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/internal/ShardedDaemonProcessImpl.scala +++ b/akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/internal/ShardedDaemonProcessImpl.scala @@ -168,7 +168,7 @@ private[akka] final class ShardedDaemonProcessImpl(system: ActorSystem[_]) messageClass: Class[T], name: String, numberOfInstances: Int, - behaviorFactory: function.Function[Int, Behavior[T]], + behaviorFactory: function.Function[Integer, Behavior[T]], stopMessage: T): Unit = init(name, numberOfInstances, n => behaviorFactory(n), ShardedDaemonProcessSettings(system), Some(stopMessage))( ClassTag(messageClass)) diff --git a/akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/javadsl/ShardedDaemonProcess.scala b/akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/javadsl/ShardedDaemonProcess.scala index cfead91abf..b6b63eb98c 100644 --- a/akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/javadsl/ShardedDaemonProcess.scala +++ b/akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/javadsl/ShardedDaemonProcess.scala @@ -56,7 +56,7 @@ abstract class ShardedDaemonProcess { messageClass: Class[T], name: String, numberOfInstances: Int, - behaviorFactory: function.Function[Int, Behavior[T]], + behaviorFactory: function.Function[Integer, Behavior[T]], stopMessage: T): Unit /**