Packages

object ReliableProxy

Annotations
@deprecated
Deprecated

(Since version 2.5.0) Use AtLeastOnceDelivery instead

Source
ReliableProxy.scala
Linear Supertypes
AnyRef, Any
Content Hierarchy
ConnectingActiveIdleState
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ReliableProxy
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. final case class Message(msg: Any, sender: ActorRef, serial: Int) extends Product with Serializable
  2. final case class ProxyTerminated(actor: ActorRef, outstanding: Unsent) extends Product with Serializable

    ProxyTerminated is sent to transition subscribers during postStop.

    ProxyTerminated is sent to transition subscribers during postStop. Any outstanding unsent messages are contained the Unsent object.

  3. class Receiver extends Actor with ReliableProxyDebugLogging
  4. sealed trait State extends AnyRef
  5. final case class TargetChanged(ref: ActorRef) extends Product with Serializable

    TargetChanged is sent to transition subscribers when the initial connection is made the target and when the target ActorRef has changed (for example, the target system crashed and has been restarted).

  6. final case class Unsent(queue: Vector[Message]) extends Product with Serializable

Value Members

  1. val active: Active.type
  2. def compare(a: Int, b: Int): Int

    Wrap-around aware comparison of integers: differences limited to 2**31-1 in magnitude will work correctly.

  3. val idle: Idle.type
  4. def props(targetPath: ActorPath, retryAfter: FiniteDuration): Props

    Props with no reconnections.

    Props with no reconnections. Arguments are detailed in the akka.contrib.pattern.ReliableProxy constructor.

  5. def props(targetPath: ActorPath, retryAfter: FiniteDuration, reconnectAfter: FiniteDuration): Props

    Props with no limit on reconnections.

    Props with no limit on reconnections. Arguments are detailed in the akka.contrib.pattern.ReliableProxy constructor.

  6. def props(targetPath: ActorPath, retryAfter: FiniteDuration, reconnectAfter: FiniteDuration, maxReconnects: Int): Props

    Java API Props.

    Java API Props. Arguments are detailed in the akka.contrib.pattern.ReliableProxy constructor.

  7. def props(targetPath: ActorPath, retryAfter: FiniteDuration, reconnectAfter: Option[FiniteDuration], maxReconnects: Option[Int]): Props

    Scala API Props.

    Scala API Props. Arguments are detailed in the akka.contrib.pattern.ReliableProxy constructor.

  8. def receiver(target: ActorRef, currentSerial: Int): Props
  9. val reconnecting: Connecting.type
  10. object Active extends State with Product with Serializable
  11. object Connecting extends State with Product with Serializable
  12. object Idle extends State with Product with Serializable