object AtLeastOnceComplete
- Alphabetic
- By Inheritance
- AtLeastOnceComplete
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def askTo(destination: ActorRef, message: Any, retryInterval: FiniteDuration)(implicit system: ActorSystem, timeout: Timeout): Future[Any]
- 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.
- 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.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()