public class DefaultQuarantineHandler extends Object implements QuarantineHandler
Constructor and Description |
---|
DefaultQuarantineHandler(Time timeout,
int exitCode,
org.slf4j.Logger log) |
Modifier and Type | Method and Description |
---|---|
void |
hasQuarantined(String remoteSystem,
akka.actor.ActorSystem actorSystem)
Callback when the given actor system has quarantined the given remote actor system.
|
void |
wasQuarantinedBy(String remoteSystem,
akka.actor.ActorSystem actorSystem)
Callback when the given actor system was quarantined by the given remote actor system.
|
public DefaultQuarantineHandler(Time timeout, int exitCode, org.slf4j.Logger log)
public void wasQuarantinedBy(String remoteSystem, akka.actor.ActorSystem actorSystem)
QuarantineHandler
wasQuarantinedBy
in interface QuarantineHandler
remoteSystem
- is the address of the remote actor system which has quarantined this
actor systemactorSystem
- which has been quarantinedpublic void hasQuarantined(String remoteSystem, akka.actor.ActorSystem actorSystem)
QuarantineHandler
hasQuarantined
in interface QuarantineHandler
remoteSystem
- is the address of the remote actor system which has been quarantined
by our actor systemactorSystem
- which has quarantined the other actor systemCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.