Packages

o

lerna.akka.entityreplication.util

AtLeastOnceComplete

object AtLeastOnceComplete

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AtLeastOnceComplete
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def askTo(destination: ActorRef, message: Any, retryInterval: FiniteDuration)(implicit system: ActorSystem, timeout: Timeout): Future[Any]
  2. def askTo[Message, Reply](destination: RecipientRef[Message], message: (ActorRef[Reply]) => Message, retryInterval: FiniteDuration)(implicit system: ActorSystem[_], timeout: Timeout): Future[Reply]

    Asks the destination with retrying until timeout.

    Asks the destination with retrying until timeout. The message will be sent multiple times for each retryInterval. It will stop when it receives the response from the destination. Note that the destination may be receive the same message even if it responds due to a delay in message arrival. The returned Future will be failed with an java.util.concurrent.TimeoutException after the given timeout has expired.

  3. def askWithStatusTo[Message, Reply](destination: RecipientRef[Message], message: (ActorRef[StatusReply[Reply]]) => Message, retryInterval: FiniteDuration)(implicit system: ActorSystem[_], timeout: Timeout): Future[Reply]

    Asks the destination with retrying until timeout.

    Asks the destination with retrying until timeout. The message will be sent multiple times for each retryInterval. It will stop when it receives the response from the destination. Note that the destination may be receive the same message even if it responds due to a delay in message arrival. The returned Future will be failed with an java.util.concurrent.TimeoutException after the given timeout has expired. The Future will also failed if a akka.pattern.StatusReply.Error arrives.