public class FailureDetector extends akka.actor.UntypedActor
|Constructor and Description|
Creates a new instance which scans all outstanding jobs at the given interval and resends the
|Modifier and Type||Method and Description|
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, getContext, getSelf, getSender, postRestart, postStop, preRestart, receive, self, sender, supervisorStrategy, unhandled
public FailureDetector(akka.actor.ActorRef master, long scanInterval, long timeoutMillis, int maxRetries)
Workif it has exceeded the timeout.
master- the actor to which to resend the work
scanInterval- the interval (in milliseconds) at which to scan the list of outstanding job
timeoutMillis- the amount of time (in milliseconds) after which work is considered 'expired'
maxRetries- the maximum number of times work can be sent
Copyright © 2010-2016 Numerical Method Incorporation Limited. All Rights Reserved.