-
Interfaces Interface Description akka.actor.UntypedActorContext Use AbstractActor.ActorContext instead of UntypedActorContext. Since 2.5.0.akka.camel.Consumer Akka Camel is deprecated in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel). Since 2.5.0.akka.camel.Oneway Akka Camel is deprecated in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel). Since 2.5.0.akka.camel.Producer Akka Camel is deprecated in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel). Since 2.5.0.akka.contrib.jul.JavaLogging Feel free to copy. Since 2.5.0.akka.contrib.jul.JavaLoggingAdapter Feel free to copy. Since 2.5.0.akka.contrib.pattern.Aggregator Feel free to copy. Since 2.5.0.akka.contrib.pattern.ReceivePipeline Feel free to copy. Since 2.5.0.akka.pattern.BackoffOptions Use new API from BackoffOpts object instead. Since 2.5.22.akka.remote.transport.netty.UdpHandlers Deprecated in favour of Artery (the new Aeron/UDP based remoting implementation). Since 2.5.0.akka.stream.actor.ActorPublisher Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant. Since 2.5.0.akka.stream.actor.ActorSubscriber Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant. Since 2.5.0.
-
Classes Class Description akka.actor.ActorDSL deprecated Use the normal `actorOf` methods defined on `ActorSystem` and `ActorContext` to create Actors instead. Since 2.5.0.akka.actor.ActorDSL$ deprecated Use the normal `actorOf` methods defined on `ActorSystem` and `ActorContext` to create Actors instead. Since 2.5.0.akka.actor.ExtensionKey Use a regular Extension instead. Since 2.5.0.akka.actor.UntypedActor Use AbstractActor instead of UntypedActor. Since 2.5.0.akka.actor.UntypedActorWithStash Use AbstractActorWithStash instead of UntypedActorWithStash. Since 2.5.0.akka.actor.UntypedActorWithUnboundedStash Use AbstractActorWithUnboundedStash instead of UntypedActorWithUnboundedStash. Since 2.5.0.akka.actor.UntypedActorWithUnrestrictedStash Use AbstractActorWithUnrestrictedStash instead of UntypedActorWithUnrestrictedStash. Since 2.5.0.akka.agent.Agent Agents are deprecated and scheduled for removal in the next major version, use Actors instead. Since 2.5.0.akka.agent.Agent$ Agents are deprecated and scheduled for removal in the next major version, use Actors instead. Since 2.5.0.akka.camel.CamelMessage Akka Camel is deprecated in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel). Since 2.5.0.akka.camel.CamelMessage$ Akka Camel is deprecated in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel). Since 2.5.0.akka.camel.Consumer$ Akka Camel is deprecated in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel). Since 2.5.0.akka.contrib.circuitbreaker.AskeableWithCircuitBreakerActor Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.akka.contrib.circuitbreaker.AskeableWithCircuitBreakerActor$ Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.akka.contrib.circuitbreaker.AskeableWithCircuitBreakerActorSelection Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.akka.contrib.circuitbreaker.AskeableWithCircuitBreakerActorSelection$ Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.akka.contrib.circuitbreaker.CircuitBreakerAwareFuture Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.akka.contrib.circuitbreaker.CircuitBreakerAwareFuture$ Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.akka.contrib.circuitbreaker.CircuitBreakerProxy Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.akka.contrib.circuitbreaker.CircuitBreakerProxy$ Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.akka.contrib.circuitbreaker.Implicits Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.akka.contrib.circuitbreaker.Implicits$ Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.akka.contrib.jul.JavaLogger Use akka.event.jul.JavaLogger in akka-actor instead. Since 2.5.0.akka.contrib.mailbox.PeekMailbox Use an explicit supervisor or proxy actor instead. Since 2.5.0.akka.contrib.mailbox.PeekMailboxExtension Use an explicit supervisor or proxy actor instead. Since 2.5.0.akka.contrib.mailbox.PeekMailboxExtension$ Use an explicit supervisor or proxy actor instead. Since 2.5.0.akka.contrib.mailbox.PeekMailboxType Use an explicit supervisor or proxy actor instead. Since 2.5.0.akka.contrib.pattern.ReceivePipeline$ Feel free to copy. Since 2.5.0.akka.contrib.pattern.ReliableProxy Use AtLeastOnceDelivery instead. Since 2.5.0.akka.contrib.pattern.ReliableProxy$ Use AtLeastOnceDelivery instead. Since 2.5.0.akka.contrib.pattern.WorkList Feel free to copy. Since 2.5.0.akka.contrib.pattern.WorkList$ Feel free to copy. Since 2.5.0.akka.contrib.throttle.Throttler Use streams, see migration guide. Since 2.5.0.akka.contrib.throttle.Throttler$ Use streams, see migration guide. Since 2.5.0.akka.contrib.throttle.TimerBasedThrottler Use streams, see migration guide. Since 2.5.0.akka.contrib.throttle.TimerBasedThrottler$ Use streams, see migration guide. Since 2.5.0.akka.dispatch.BalancingDispatcher Use BalancingPool instead of BalancingDispatcher. Since 2.3.akka.dispatch.japi.BooleanFunctionBridge Do not use this directly, use subclasses of this. Since 2.0.akka.dispatch.japi.CallbackBridge Do not use this directly, use subclasses of this. Since 2.0.akka.dispatch.japi.RecoverBridge Do not use this directly, use 'Recover'. Since 2.0.akka.dispatch.japi.UnitFunctionBridge Do not use this directly, use subclasses of this. Since 2.0.akka.io.Tcp.WriteFile Use WritePath instead. Since 2.5.10.akka.io.Tcp.WriteFile$ Use WritePath instead. Since 2.5.10.akka.pattern.Backoff Use new API from BackoffOpts object instead. Since 2.5.22.akka.pattern.Backoff$ Use new API from BackoffOpts object instead. Since 2.5.22.akka.pattern.PatternsCS Use Patterns instead. Since 2.5.19.akka.pattern.PatternsCS$ Use Patterns instead. Since 2.5.19.akka.persistence.UntypedPersistentActor Use AbstractPersistentActor instead of UntypedPersistentActor. Since 2.5.0.akka.persistence.UntypedPersistentActorWithAtLeastOnceDelivery Use AbstractPersistentActorWithAtLeastOnceDelivery instead. Since 2.5.0.akka.remote.transport.FailureInjectorTransportAdapter.All Not implemented. Since 2.5.22.akka.remote.transport.FailureInjectorTransportAdapter.All$ Not implemented. Since 2.5.22.akka.remote.transport.netty.UdpClientHandler Deprecated in favour of Artery (the new Aeron/UDP based remoting implementation). Since 2.5.0.akka.remote.transport.netty.UdpServerHandler Deprecated in favour of Artery (the new Aeron/UDP based remoting implementation). Since 2.5.0.akka.stream.actor.AbstractActorPublisher Useakka.stream.stage.GraphStage
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.actor.AbstractActorPublisher$ Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant. Since 2.5.0.akka.stream.actor.AbstractActorPublisherWithStash Useakka.stream.stage.GraphStage
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.actor.AbstractActorPublisherWithUnboundedStash Useakka.stream.stage.GraphStage
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.actor.AbstractActorPublisherWithUnrestrictedStash Useakka.stream.stage.GraphStage
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.actor.AbstractActorSubscriber Useakka.stream.stage.GraphStage
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.actor.AbstractActorSubscriber$ Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant. Since 2.5.0.akka.stream.actor.ActorPublisher$ Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant. Since 2.5.0.akka.stream.actor.ActorSubscriber$ Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant. Since 2.5.0.akka.stream.actor.UntypedActorPublisher Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant. Since 2.5.0.akka.stream.actor.UntypedActorPublisher$ Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant. Since 2.5.0.akka.stream.actor.UntypedActorSubscriber Useakka.stream.stage.GraphStage
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.actor.UntypedActorSubscriber$ Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant. Since 2.5.0.akka.stream.extra.Timed Moved to the akka/akka-stream-contrib project. Since 2.4.5.akka.stream.extra.Timed$ Moved to the akka/akka-stream-contrib project. Since 2.4.5.akka.stream.FanInShape1N FanInShape1N was removed because it was not used anywhere. Use a custom shape extending from FanInShape directly. Since 2.5.5.akka.stream.impl.ConstantFun Use akka.util.ConstantFun instead. Since 2.5.0.akka.stream.impl.ConstantFun$ Use akka.util.ConstantFun instead. Since 2.5.0.akka.testkit.CachingPartialFunction The only usage is in JavaTestKit which is deprecated. Since 2.5.0.akka.testkit.JavaTestKit UseTestKit
instead, since 2.5.0
-
Exceptions Exceptions Description akka.contrib.circuitbreaker.OpenCircuitException Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.akka.contrib.circuitbreaker.OpenCircuitException$ Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.akka.stream.BindFailedException$ BindFailedException object will never be thrown. Match on the class instead. Since 2.4.19.
-
Methods Method Description akka.actor.AbstractActor.ActorContext.getChild(String) Use findChild instead. Since 2.5.0.akka.actor.AbstractActor.preRestart(Throwable, Option<Object>) Override preRestart with message parameter with Optional type instead. Since 2.5.0.akka.actor.AbstractProps.create(Creator<T>) Use Props.create(actorClass, creator) instead, since this can't be used with Java 8 lambda. Since 2.5.18.akka.actor.ActorIdentity.getRef() Use getActorRef instead. Since 2.5.0.akka.actor.ActorRefFactory.actorFor(ActorPath) use actorSelection instead of actorFor. Since 2.2.akka.actor.ActorRefProvider.actorFor(ActorPath) use actorSelection instead of actorFor. Since 2.2.akka.actor.ActorSelection.resolveOneCS(FiniteDuration) Use the overloaded method resolveOne which accepts java.time.Duration instead. Since 2.5.20.akka.actor.CoordinatedShutdown.run() Use the method with `reason` parameter instead. Since 2.5.8.akka.actor.CoordinatedShutdown.runAll() Use the method with `reason` parameter instead. Since 2.5.8.akka.actor.EmptyLocalActorRef.isTerminated() Use context.watch(actor) and receive Terminated(actor). Since 2.2.akka.actor.LocalActorRefProvider.actorFor(InternalActorRef, String) use actorSelection instead of actorFor. Since 2.2.akka.actor.MinimalActorRef.isTerminated() Use context.watch(actor) and receive Terminated(actor). Since 2.2.akka.actor.RepointableActorRef.isTerminated() Use context.watch(actor) and receive Terminated(actor). Since 2.2.akka.actor.typed.javadsl.Adapter.toUntyped(ActorSystem<?>) Use 'toClassic' instead. Since 2.5.26.akka.actor.typed.javadsl.Adapter$.toUntyped(ActorSystem<?>) Use 'toClassic' instead. Since 2.5.26.akka.agent.Agent.create(T, ExecutionContext) Agents are deprecated and scheduled for removal in the next major version, use Actors instead.iakka.agent.Agent$.apply(T, ExecutionContext) Agents are deprecated and scheduled for removal in the next major version, use Actors instead. Since 2.5.0.akka.agent.Agent$.create(T, ExecutionContext) Agents are deprecated and scheduled for removal in the next major version, use Actors instead.iakka.cluster.ClusterSettings.DownRemovalMargin() Specific toAutoDown
should not be used anywhere else, insteadCluster.downingProvider.downRemovalMargin
should be used as it allows the downing provider to decide removal margins
akka.cluster.ddata.GCounter.$plus(long, Cluster) Use `:+` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.GCounter.increment(Cluster, long) Use `increment` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.LWWMap.$minus(A, Cluster) Use `remove` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.LWWMap.$plus(Tuple2<A, B>, Cluster) Use `:+` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.LWWMap.put(Cluster, A, B) Use `put` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.LWWMap.remove(Cluster, A) Use `remove` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.LWWRegister.apply(A, Cluster, LWWRegister.Clock<A>) Use `apply` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.LWWRegister.create(Cluster, A) Use `create` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.LWWRegister.withValue(A, Cluster, LWWRegister.Clock<A>) Use `withValueOf` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.LWWRegister$.apply(A, Cluster, LWWRegister.Clock<A>) Use `apply` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.LWWRegister$.create(Cluster, A) Use `create` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORMap.$minus(A, Cluster) Use `remove` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORMap.$plus(Tuple2<A, B>, Cluster) Use `:+` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORMap.put(Cluster, A, B) Use `put` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORMap.remove(Cluster, A) Use `remove` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORMap.update(Cluster, A, B, Function<B, B>) Use `update` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORMap.updated(Cluster, A, B, Function1<B, B>) Use `updated` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORMultiMap.$minus(A, Cluster) Use `remove` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORMultiMap.$plus(Tuple2<A, Set<B>>, Cluster) Use `:+` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORMultiMap.addBinding(A, B, Cluster) Use `addBinding` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORMultiMap.put(Cluster, A, Set<B>) Use `put` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORMultiMap.remove(Cluster, A) Use `remove` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORMultiMap.removeBinding(A, B, Cluster) Use `removeBinding` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORMultiMap.replaceBinding(A, B, B, Cluster) Use `replaceBinding` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORSet.$minus(A, Cluster) Use `remove` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORSet.$plus(A, Cluster) Use `:+` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORSet.add(Cluster, A) Use `add` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORSet.clear(Cluster) Use `remove` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.ORSet.remove(Cluster, A) Use `remove` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.PNCounter.$minus(long, Cluster) Use `decrement` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.PNCounter.$plus(long, Cluster) Use `:+` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.PNCounter.decrement(Cluster, long) Use `decrement` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.PNCounter.increment(Cluster, long) Use `increment` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.PNCounterMap.$minus(A, Cluster) Use `remove` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.PNCounterMap.decrement(A, long, Cluster) Use `decrement` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.PNCounterMap.increment(Cluster, A, long) Use `increment` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.PNCounterMap.remove(Cluster, A) Use `remove` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.VersionVector.$plus(Cluster) Use `:+` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.ddata.VersionVector.increment(Cluster) Use `increment` that takes a `SelfUniqueAddress` parameter instead. Since 2.5.20.akka.cluster.Member.pickHighestPriority(Set<Member>, Set<Member>) Was accidentally made a public API, internal. Since 2.5.4.akka.cluster.Member$.pickHighestPriority(Set<Member>, Set<Member>) Was accidentally made a public API, internal. Since 2.5.4.akka.cluster.routing.ClusterRouterGroupSettings.apply(int, Seq<String>, boolean, Option<String>) useRole has been replaced with useRoles. Since 2.5.4.akka.cluster.routing.ClusterRouterGroupSettings.copy(int, Seq<String>, boolean, Option<String>) Use constructor with useRoles instead. Since 2.5.4.akka.cluster.routing.ClusterRouterGroupSettings.useRole() useRole has been replaced with useRoles. Since 2.5.4.akka.cluster.routing.ClusterRouterGroupSettings$.apply(int, Seq<String>, boolean, Option<String>) useRole has been replaced with useRoles. Since 2.5.4.akka.cluster.routing.ClusterRouterPoolSettings.apply(int, int, boolean, Option<String>) useRole has been replaced with useRoles. Since 2.5.4.akka.cluster.routing.ClusterRouterPoolSettings.copy(int, int, boolean, Option<String>) Use copy with useRoles instead. Since 2.5.4.akka.cluster.routing.ClusterRouterPoolSettings.useRole() useRole has been replaced with useRoles. Since 2.5.4.akka.cluster.routing.ClusterRouterPoolSettings$.apply(int, int, boolean, Option<String>) useRole has been replaced with useRoles. Since 2.5.4.akka.cluster.UniqueAddress.apply(Address, int) Use Long UID apply instead. Since 2.4.11.akka.cluster.UniqueAddress.copy(Address, int) Use Long UID constructor instead. Since 2.4.11.akka.cluster.UniqueAddress.uid() Use longUid instead. Since 2.4.11.akka.cluster.UniqueAddress$.apply(Address, int) Use Long UID apply instead. Since 2.4.11.akka.event.Logging.getLogger(UntypedActor) Use AbstractActor instead of UntypedActor. Since 2.5.0.akka.event.Logging$.getLogger(UntypedActor) Use AbstractActor instead of UntypedActor. Since 2.5.0.akka.event.LoggingReceive.create(PartialFunction<Object, BoxedUnit>, ActorContext) Use the create method with `AbstractActor.Receive` parameter instead. Since 2.5.0.akka.event.LoggingReceive$.create(PartialFunction<Object, BoxedUnit>, ActorContext) Use the create method with `AbstractActor.Receive` parameter instead. Since 2.5.0.akka.event.LogMarker.extractFromMDC(Map<String, Object>) use akka.event.LogEventWithMarker#marker instead. Since 2.5.12.akka.event.LogMarker$.extractFromMDC(Map<String, Object>) use akka.event.LogEventWithMarker#marker instead. Since 2.5.12.akka.io.InetAddressDnsResolver.negativeTtl() Use negativeCacheDuration instead. Since 2.5.17.akka.io.InetAddressDnsResolver.positiveTtl() Use positiveCacheDuration instead. Since 2.5.17.akka.pattern.Backoff.onFailure(Props, String, FiniteDuration, FiniteDuration, double, int) Use BackoffOpts.onFailure instead. Since 2.5.22.akka.pattern.Backoff.onStop(Props, String, FiniteDuration, FiniteDuration, double, int) Use BackoffOpts.onStop instead. Since 2.5.22.akka.pattern.Backoff$.onFailure(Props, String, FiniteDuration, FiniteDuration, double, int) Use BackoffOpts.onFailure instead. Since 2.5.22.akka.pattern.Backoff$.onStop(Props, String, FiniteDuration, FiniteDuration, double, int) Use BackoffOpts.onStop instead. Since 2.5.22.akka.pattern.BackoffSupervisor.props(Props, String, FiniteDuration, FiniteDuration, double) Use props with BackoffOpts instead. Since 2.5.22.akka.pattern.BackoffSupervisor.propsWithSupervisorStrategy(Props, String, FiniteDuration, FiniteDuration, double, SupervisorStrategy) Use props with BackoffOpts instead. Since 2.5.22.akka.pattern.BackoffSupervisor$.props(Props, String, FiniteDuration, FiniteDuration, double) Use props with BackoffOpts instead. Since 2.5.22.akka.pattern.BackoffSupervisor$.propsWithSupervisorStrategy(Props, String, FiniteDuration, FiniteDuration, double, SupervisorStrategy) Use props with BackoffOpts instead. Since 2.5.22.akka.pattern.CircuitBreaker.create(Scheduler, int, FiniteDuration, FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.pattern.CircuitBreaker.onClose(Runnable) Use addOnCloseListener instead. Since 2.5.0.akka.pattern.CircuitBreaker.onHalfOpen(Runnable) Use addOnHalfOpenListener instead. Since 2.5.0.akka.pattern.CircuitBreaker.onOpen(Runnable) Use addOnOpenListener instead. Since 2.5.0.akka.pattern.CircuitBreaker$.create(Scheduler, int, FiniteDuration, FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.pattern.Patterns.after(FiniteDuration, Scheduler, ExecutionContext, Future<T>) Use the overload one which accepts a Callable of Future instead. Since 2.5.22.akka.pattern.Patterns$.after(FiniteDuration, Scheduler, ExecutionContext, Future<T>) Use the overload one which accepts a Callable of Future instead. Since 2.5.22.akka.pattern.PatternsCS.after(FiniteDuration, Scheduler, ExecutionContext, Callable<CompletionStage<T>>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.pattern.PatternsCS.ask(ActorRef, Object, Timeout) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.15.akka.pattern.PatternsCS.askWithReplyTo(ActorRef, Function<ActorRef, Object>, Timeout) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.15.akka.pattern.PatternsCS.gracefulStop(ActorRef, FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.pattern.PatternsCS.pipe(CompletionStage<T>, ExecutionContext) Use Patterns.pipe instead. Since 2.5.19.akka.pattern.PatternsCS.retry(Callable<CompletionStage<T>>, int, Duration, Scheduler, ExecutionContext) Use Patterns.retry instead. Since 2.5.19.akka.pattern.PatternsCS$.after(FiniteDuration, Scheduler, ExecutionContext, Callable<CompletionStage<T>>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.pattern.PatternsCS$.ask(ActorRef, Object, Timeout) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.15.akka.pattern.PatternsCS$.askWithReplyTo(ActorRef, Function<ActorRef, Object>, Timeout) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.15.akka.pattern.PatternsCS$.gracefulStop(ActorRef, FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.pattern.PatternsCS$.pipe(CompletionStage<T>, ExecutionContext) Use Patterns.pipe instead. Since 2.5.19.akka.pattern.PatternsCS$.retry(Callable<CompletionStage<T>>, int, Duration, Scheduler, ExecutionContext) Use Patterns.retry instead. Since 2.5.19.akka.persistence.fsm.PersistentFSM.State.using(D) Internal API easily to be confused with regular FSM's using. Use regular events (`applying`). Internally, `copy` can be used instead. Since 2.5.5.akka.persistence.fsm.PersistentFSMBase.initialize() Removed from API, called internally. Since 2.4.5.akka.remote.AddressUidExtension.addressUid() Use longAddressUid instead. Since 2.4.x.akka.remote.QuarantinedEvent.apply(Address, int) Use long uid apply. Since 2.4.x.akka.remote.QuarantinedEvent.copy(Address, int) Use long uid copy method. Since 2.4.x.akka.remote.QuarantinedEvent.uid() Use long uid. Since 2.4.x.akka.remote.QuarantinedEvent$.apply(Address, int) Use long uid apply. Since 2.4.x.akka.remote.RemoteActorRef.isTerminated() Use context.watch(actor) and receive Terminated(actor). Since 2.2.akka.remote.RemoteActorRefProvider.actorFor(ActorPath) use actorSelection instead of actorFor. Since 2.2.akka.remote.transport.AssociationHandle.disassociate() Use method that states reasons to make sure disassociation reasons are logged. Since 2.5.3.akka.remote.transport.FailureInjectorHandle.disassociate() Use method that states reasons to make sure disassociation reasons are logged. Since 2.5.3.akka.remote.transport.netty.NettyTransportSettings.BindPortSelector() WARNING: This should only be used by professionals. Since 2.4.akka.remote.transport.netty.NettyTransportSettings.PortSelector() WARNING: This should only be used by professionals. Since 2.0.akka.stream.ActorMaterializerSettings.apply(int, int, String, Function1<Throwable, Supervision.Directive>, StreamSubscriptionTimeoutSettings, boolean, int, boolean, boolean, int) Create the settings using the apply(system) or apply(config) method, and then modify them using the .with methods. Since 2.5.10.akka.stream.ActorMaterializerSettings.create(int, int, String, Function1<Throwable, Supervision.Directive>, StreamSubscriptionTimeoutSettings, boolean, int, boolean, boolean, int) Create the settings using the create(system) or create(config) method, and then modify them using the .with methods. Since 2.5.10.akka.stream.ActorMaterializerSettings.withAutoFusing(boolean) Turning off fusing is no longer possible with the traversal based materializer. Since 2.5.0.akka.stream.ActorMaterializerSettings$.apply(int, int, String, Function1<Throwable, Supervision.Directive>, StreamSubscriptionTimeoutSettings, boolean, int, boolean, boolean, int) Create the settings using the apply(system) or apply(config) method, and then modify them using the .with methods. Since 2.5.10.akka.stream.ActorMaterializerSettings$.create(int, int, String, Function1<Throwable, Supervision.Directive>, StreamSubscriptionTimeoutSettings, boolean, int, boolean, boolean, int) Create the settings using the create(system) or create(config) method, and then modify them using the .with methods. Since 2.5.10.akka.stream.Attributes.getFirst(T, ClassTag<T>) Attributes should always be most specific, use get[T]. Since 2.5.7.akka.stream.Attributes.getFirstAttribute(Class<T>, T) Attributes should always be most specific, use getAttribute[T]. Since 2.5.7.akka.stream.extra.TimedIntervalBetweenOps.timedIntervalBetween(Source<O, Mat>, Function1<O, Object>, Function1<FiniteDuration, BoxedUnit>) Moved to the akka/akka-stream-contrib project. Since 2.4.5.akka.stream.extra.TimedOps.timed(Source<I, Mat>, Function1<Source<I, Mat>, Source<O, Mat2>>, Function1<FiniteDuration, BoxedUnit>) Moved to the akka/akka-stream-contrib project. Since 2.4.5.akka.stream.FanInShape1N.in1Seq() Use 'inlets' or 'in(id)' instead. Since 2.5.5.akka.stream.javadsl.BidiFlow.bidirectionalIdleTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.BidiFlow$.bidirectionalIdleTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.CoupledTerminationFlow.fromSinkAndSource(Sink<I, M1>, Source<O, M2>) Use `Flow.fromSinkAndSourceCoupledMat(..., ..., Keep.both())` instead. Since 2.5.2.akka.stream.javadsl.CoupledTerminationFlow$.fromSinkAndSource(Sink<I, M1>, Source<O, M2>) Use `Flow.fromSinkAndSourceCoupledMat(..., ..., Keep.both())` instead. Since 2.5.2.akka.stream.javadsl.FileIO.fromFile(File) Use `fromPath` instead. Since 2.4.5.akka.stream.javadsl.FileIO.toFile(File) Use `toPath` instead. Since 2.4.5.akka.stream.javadsl.FileIO$.fromFile(File) Use `fromPath` instead. Since 2.4.5.akka.stream.javadsl.FileIO$.toFile(File) Use `toPath` instead. Since 2.4.5.akka.stream.javadsl.Flow.backpressureTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Flow.completionTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Flow.delay(FiniteDuration, DelayOverflowStrategy) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Flow.dropWithin(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Flow.groupedWeightedWithin(long, Function<Out, Long>, FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Flow.groupedWithin(int, FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Flow.idleTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Flow.initialDelay(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Flow.initialTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Flow.keepAlive(FiniteDuration, Creator<Out>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Flow.lazyInit(Function<I, CompletionStage<Flow<I, O, M>>>, Creator<M>) Use lazyInitAsync instead. (lazyInitAsync returns a flow with a more useful materialized value.). Since 2.5.12.akka.stream.javadsl.Flow.monitor(Function2<Mat, FlowMonitor<Out>, M>) Use monitor() or monitorMat(combine) instead. Since 2.5.17.akka.stream.javadsl.Flow.recover(PartialFunction<Throwable, Out>) Use recoverWithRetries instead. Since 2.4.4.akka.stream.javadsl.Flow.takeWithin(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Flow.throttle(int, FiniteDuration, int, ThrottleMode) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Flow.throttleEven(int, FiniteDuration, ThrottleMode) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Flow$.lazyInit(Function<I, CompletionStage<Flow<I, O, M>>>, Creator<M>) Use lazyInitAsync instead. (lazyInitAsync returns a flow with a more useful materialized value.). Since 2.5.12.akka.stream.javadsl.RestartFlow.onFailuresWithBackoff(FiniteDuration, FiniteDuration, double, int, Creator<Flow<In, Out, ?>>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.RestartFlow.withBackoff(FiniteDuration, FiniteDuration, double, Creator<Flow<In, Out, ?>>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.RestartFlow$.onFailuresWithBackoff(FiniteDuration, FiniteDuration, double, int, Creator<Flow<In, Out, ?>>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.RestartFlow$.withBackoff(FiniteDuration, FiniteDuration, double, Creator<Flow<In, Out, ?>>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.RestartSink.withBackoff(FiniteDuration, FiniteDuration, double, Creator<Sink<T, ?>>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.RestartSink$.withBackoff(FiniteDuration, FiniteDuration, double, Creator<Sink<T, ?>>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.RestartSource.onFailuresWithBackoff(FiniteDuration, FiniteDuration, double, Creator<Source<T, ?>>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.RestartSource.withBackoff(FiniteDuration, FiniteDuration, double, Creator<Source<T, ?>>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.RestartSource$.onFailuresWithBackoff(FiniteDuration, FiniteDuration, double, Creator<Source<T, ?>>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.RestartSource$.withBackoff(FiniteDuration, FiniteDuration, double, Creator<Source<T, ?>>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Sink.actorSubscriber(Props) Useakka.stream.stage.GraphStage
andfromGraph
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.javadsl.Sink.foreachParallel(int, Procedure<T>, ExecutionContext) Use `foreachAsync` instead, it allows you to choose how to run the procedure, by calling some other API returning a CompletionStage or using CompletableFuture.supplyAsync. Since 2.5.17.akka.stream.javadsl.Sink.lazyInit(Function<T, CompletionStage<Sink<T, M>>>, Creator<M>) Use lazyInitAsync instead. (lazyInitAsync no more needs a fallback function and the materialized value more clearly indicates if the internal sink was materialized or not.). Since 2.5.11.akka.stream.javadsl.Sink$.actorSubscriber(Props) Useakka.stream.stage.GraphStage
andfromGraph
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.javadsl.Sink$.foreachParallel(int, Procedure<T>, ExecutionContext) Use `foreachAsync` instead, it allows you to choose how to run the procedure, by calling some other API returning a CompletionStage or using CompletableFuture.supplyAsync. Since 2.5.17.akka.stream.javadsl.Sink$.lazyInit(Function<T, CompletionStage<Sink<T, M>>>, Creator<M>) Use lazyInitAsync instead. (lazyInitAsync no more needs a fallback function and the materialized value more clearly indicates if the internal sink was materialized or not.). Since 2.5.11.akka.stream.javadsl.Source.actorPublisher(Props) Useakka.stream.stage.GraphStage
andfromGraph
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.javadsl.Source.backpressureTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Source.completionTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Source.delay(FiniteDuration, DelayOverflowStrategy) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Source.dropWithin(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Source.groupedWeightedWithin(long, Function<Out, Long>, FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Source.groupedWithin(int, FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Source.idleTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Source.initialDelay(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Source.initialTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Source.keepAlive(FiniteDuration, Creator<Out>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Source.monitor(Function2<Mat, FlowMonitor<Out>, M>) Use monitor() or monitorMat(combine) instead. Since 2.5.17.akka.stream.javadsl.Source.recover(PartialFunction<Throwable, Out>) Use recoverWithRetries instead. Since 2.4.4.akka.stream.javadsl.Source.takeWithin(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Source.throttle(int, FiniteDuration, int, ThrottleMode) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Source.throttleEven(int, FiniteDuration, ThrottleMode) Use throttle without `maximumBurst` parameter instead. Since 2.5.12.akka.stream.javadsl.Source.tick(FiniteDuration, FiniteDuration, O) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.Source$.actorPublisher(Props) Useakka.stream.stage.GraphStage
andfromGraph
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.javadsl.Source$.tick(FiniteDuration, FiniteDuration, O) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.StreamConverters.asInputStream(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.StreamConverters.asOutputStream(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.StreamConverters$.asInputStream(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.StreamConverters$.asOutputStream(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubFlow.backpressureTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubFlow.completionTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubFlow.delay(FiniteDuration, DelayOverflowStrategy) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubFlow.dropWithin(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubFlow.groupedWeightedWithin(long, Function<Out, Long>, FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubFlow.groupedWithin(int, FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubFlow.idleTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubFlow.initialDelay(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubFlow.initialTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubFlow.keepAlive(FiniteDuration, Creator<Out>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubFlow.recoverWith(PartialFunction<Throwable, Graph<SourceShape<Out>, NotUsed>>) Use recoverWithRetries instead. Since 2.4.4.akka.stream.javadsl.SubFlow.takeWithin(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubFlow.throttle(int, FiniteDuration, int, ThrottleMode) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubFlow.throttleEven(int, FiniteDuration, ThrottleMode) Use throttle without `maximumBurst` parameter instead. Since 2.5.12.akka.stream.javadsl.SubSource.backpressureTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubSource.completionTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubSource.delay(FiniteDuration, DelayOverflowStrategy) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubSource.dropWithin(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubSource.groupedWeightedWithin(long, Function<Out, Long>, FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubSource.groupedWithin(int, FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubSource.idleTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubSource.initialDelay(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubSource.initialTimeout(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubSource.keepAlive(FiniteDuration, Creator<Out>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubSource.recoverWith(PartialFunction<Throwable, Graph<SourceShape<Out>, NotUsed>>) Use recoverWithRetries instead. Since 2.4.4.akka.stream.javadsl.SubSource.takeWithin(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubSource.throttle(int, FiniteDuration, int, ThrottleMode) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.stream.javadsl.SubSource.throttleEven(int, FiniteDuration, ThrottleMode) Use throttle without `maximumBurst` parameter instead. Since 2.5.12.akka.stream.scaladsl.CoupledTerminationFlow.fromSinkAndSource(Sink<I, M1>, Source<O, M2>) Use `Flow.fromSinkAndSourceCoupledMat(..., ...)(Keep.both)` instead. Since 2.5.2.akka.stream.scaladsl.CoupledTerminationFlow$.fromSinkAndSource(Sink<I, M1>, Source<O, M2>) Use `Flow.fromSinkAndSourceCoupledMat(..., ...)(Keep.both)` instead. Since 2.5.2.akka.stream.scaladsl.FileIO.fromFile(File, int) Use `fromPath` instead. Since 2.4.5.akka.stream.scaladsl.FileIO.toFile(File, Set<OpenOption>) Use `toPath` instead. Since 2.4.5.akka.stream.scaladsl.FileIO$.fromFile(File, int) Use `fromPath` instead. Since 2.4.5.akka.stream.scaladsl.FileIO$.toFile(File, Set<OpenOption>) Use `toPath` instead. Since 2.4.5.akka.stream.scaladsl.Flow.lazyInit(Function1<I, Future<Flow<I, O, M>>>, Function0<M>) Use lazyInitAsync instead. (lazyInitAsync returns a flow with a more useful materialized value.). Since 2.5.12.akka.stream.scaladsl.Flow$.lazyInit(Function1<I, Future<Flow<I, O, M>>>, Function0<M>) Use lazyInitAsync instead. (lazyInitAsync returns a flow with a more useful materialized value.). Since 2.5.12.akka.stream.scaladsl.FlowOps.recoverWith(PartialFunction<Throwable, Graph<SourceShape<T>, NotUsed>>) Use recoverWithRetries instead. Since 2.4.4.akka.stream.scaladsl.FlowOps.throttleEven(int, FiniteDuration, ThrottleMode) Use throttle without `maximumBurst` parameter instead. Since 2.5.12.akka.stream.scaladsl.FlowOpsMat.monitor(Function2<Mat, FlowMonitor<Out>, Mat2>) Use monitor() or monitorMat(combine) instead. Since 2.5.17.akka.stream.scaladsl.Sink.actorSubscriber(Props) Useakka.stream.stage.GraphStage
andfromGraph
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.scaladsl.Sink.foreachParallel(int, Function1<T, BoxedUnit>, ExecutionContext) Use `foreachAsync` instead, it allows you to choose how to run the procedure, by calling some other API returning a Future or spawning a new Future. Since 2.5.17.akka.stream.scaladsl.Sink.lazyInit(Function1<T, Future<Sink<T, M>>>, Function0<M>) Use lazyInitAsync instead. (lazyInitAsync no more needs a fallback function and the materialized value more clearly indicates if the internal sink was materialized or not.). Since 2.5.11.akka.stream.scaladsl.Sink$.actorSubscriber(Props) Useakka.stream.stage.GraphStage
andfromGraph
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.scaladsl.Sink$.foreachParallel(int, Function1<T, BoxedUnit>, ExecutionContext) Use `foreachAsync` instead, it allows you to choose how to run the procedure, by calling some other API returning a Future or spawning a new Future. Since 2.5.17.akka.stream.scaladsl.Sink$.lazyInit(Function1<T, Future<Sink<T, M>>>, Function0<M>) Use lazyInitAsync instead. (lazyInitAsync no more needs a fallback function and the materialized value more clearly indicates if the internal sink was materialized or not.). Since 2.5.11.akka.stream.scaladsl.Source.actorPublisher(Props) Useakka.stream.stage.GraphStage
andfromGraph
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.scaladsl.Source.combine(Source<T, ?>, Source<T, ?>, Seq<Source<T, ?>>, Function1<Object, Graph<UniformFanInShape<T, U>, NotUsed>>) Use `Source.combine` on companion object instead. Since 2.5.5.akka.stream.scaladsl.Source$.actorPublisher(Props) Useakka.stream.stage.GraphStage
andfromGraph
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.akka.stream.scaladsl.ZipWithN.inSeq() use `shape.inlets` or `shape.in(id)` instead. Since 2.5.5.akka.stream.testkit.TestPublisher.ManualProbe.expectNoMsg() Use expectNoMessage instead. Since 2.5.5.akka.stream.testkit.TestSubscriber.ManualProbe.expectNoMsg() Use expectNoMessage instead. Since 2.5.5.akka.stream.typed.javadsl.ActorSource.actorRef(Predicate<T>, PartialFunction<T, Throwable>, int, OverflowStrategy) Use `actorRef` that takes japi function instead. Since 2.5.23.akka.stream.typed.javadsl.ActorSource$.actorRef(Predicate<T>, PartialFunction<T, Throwable>, int, OverflowStrategy) Use `actorRef` that takes japi function instead. Since 2.5.23.akka.stream.UniformFanInShape.inSeq() Use 'inlets' or 'in(id)' instead. Since 2.5.5.akka.stream.UniformFanOutShape.outArray() use 'outlets' or 'out(id)' instead. Since 2.5.5.akka.testkit.javadsl.TestKit.awaitAssert(Duration, Supplier<A>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.13.akka.testkit.javadsl.TestKit.awaitCond(Duration, Supplier<Object>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.testkit.javadsl.TestKit.dilated(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.testkit.javadsl.TestKit.expectMsg(FiniteDuration, T) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.testkit.javadsl.TestKit.expectMsgAllOf(FiniteDuration, Seq<T>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.testkit.javadsl.TestKit.expectMsgAnyClassOf(FiniteDuration, Seq<Class<?>>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.testkit.javadsl.TestKit.expectMsgAnyOf(FiniteDuration, Seq<T>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.testkit.javadsl.TestKit.expectMsgClass(FiniteDuration, Class<T>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.testkit.javadsl.TestKit.expectMsgEquals(FiniteDuration, T) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.testkit.javadsl.TestKit.expectNoMessage(FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.testkit.javadsl.TestKit.expectNoMsg() Use expectNoMessage instead. Since 2.5.10.akka.testkit.javadsl.TestKit.receiveN(int, FiniteDuration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.testkit.javadsl.TestKit.receiveOne(Duration) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.13.akka.testkit.javadsl.TestKit.receiveWhile(Duration, Duration, int, Function<Object, T>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.13.akka.testkit.javadsl.TestKit.remaining() Use getRemaining which returns java.time.Duration instead. Since 2.5.12.akka.testkit.javadsl.TestKit.remainingOr(FiniteDuration) Use getRemainingOr which returns java.time.Duration instead. Since 2.5.12.akka.testkit.javadsl.TestKit.remainingOrDefault() Use getRemainingOrDefault which returns java.time.Duration instead. Since 2.5.12.akka.testkit.javadsl.TestKit.within(FiniteDuration, FiniteDuration, Supplier<T>) Use the overloaded one which accepts java.time.Duration instead. Since 2.5.12.akka.testkit.TestKitBase.expectNoMsg() Use expectNoMessage instead. Since 2.5.5.