Package akka.actor.dungeon
Interface ReceiveTimeout
-
public interface ReceiveTimeout
INTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description scala.Tuple2<scala.concurrent.duration.Duration,Cancellable>
cancelReceiveTimeoutIfNeeded(java.lang.Object message)
void
cancelReceiveTimeoutTask()
void
checkReceiveTimeout(boolean reschedule)
void
checkReceiveTimeoutIfNeeded(java.lang.Object message, scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> beforeReceive)
Called after `ActorCell.receiveMessage` or `ActorCell.autoReceiveMessage`.boolean
hasTimeoutData()
boolean
messageMarkedToNotInfluenceTimeout(java.lang.Object message)
scala.concurrent.duration.Duration
receiveTimeout()
boolean
receiveTimeoutChanged(scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> beforeReceive)
void
receiveTimeoutData_$eq(scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> x$1)
void
rescheduleReceiveTimeout(scala.concurrent.duration.FiniteDuration f)
void
setReceiveTimeout(scala.concurrent.duration.Duration timeout)
-
-
-
Method Detail
-
receiveTimeoutData_$eq
void receiveTimeoutData_$eq(scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> x$1)
-
receiveTimeout
scala.concurrent.duration.Duration receiveTimeout()
-
setReceiveTimeout
void setReceiveTimeout(scala.concurrent.duration.Duration timeout)
-
checkReceiveTimeoutIfNeeded
void checkReceiveTimeoutIfNeeded(java.lang.Object message, scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> beforeReceive)
Called after `ActorCell.receiveMessage` or `ActorCell.autoReceiveMessage`.
-
checkReceiveTimeout
void checkReceiveTimeout(boolean reschedule)
-
rescheduleReceiveTimeout
void rescheduleReceiveTimeout(scala.concurrent.duration.FiniteDuration f)
-
hasTimeoutData
boolean hasTimeoutData()
-
receiveTimeoutChanged
boolean receiveTimeoutChanged(scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> beforeReceive)
-
cancelReceiveTimeoutIfNeeded
scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> cancelReceiveTimeoutIfNeeded(java.lang.Object message)
-
cancelReceiveTimeoutTask
void cancelReceiveTimeoutTask()
-
messageMarkedToNotInfluenceTimeout
boolean messageMarkedToNotInfluenceTimeout(java.lang.Object message)
-
-