|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.pattern.CircuitBreaker$
public class CircuitBreaker$
Companion object providing factory methods for Circuit Breaker which runs callbacks in caller's thread
Field Summary | |
---|---|
static CircuitBreaker$ |
MODULE$
Static reference to the singleton instance of this Scala object. |
Constructor Summary | |
---|---|
CircuitBreaker$()
|
Method Summary | |
---|---|
CircuitBreaker |
apply(Scheduler scheduler,
int maxFailures,
scala.concurrent.duration.FiniteDuration callTimeout,
scala.concurrent.duration.FiniteDuration resetTimeout)
Create a new CircuitBreaker. |
CircuitBreaker |
create(Scheduler scheduler,
int maxFailures,
scala.concurrent.duration.FiniteDuration callTimeout,
scala.concurrent.duration.FiniteDuration resetTimeout)
Java API: Create a new CircuitBreaker. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final CircuitBreaker$ MODULE$
Constructor Detail |
---|
public CircuitBreaker$()
Method Detail |
---|
public CircuitBreaker apply(Scheduler scheduler, int maxFailures, scala.concurrent.duration.FiniteDuration callTimeout, scala.concurrent.duration.FiniteDuration resetTimeout)
Callbacks run in caller's thread when using withSyncCircuitBreaker, and in same ExecutionContext as the passed in Future when using withCircuitBreaker. To use another ExecutionContext for the callbacks you can specify the executor in the constructor.
scheduler
- Reference to Akka schedulermaxFailures
- Maximum number of failures before opening the circuitcallTimeout
- FiniteDuration
of time after which to consider a call a failureresetTimeout
- FiniteDuration
of time after which to attempt to close the circuit
public CircuitBreaker create(Scheduler scheduler, int maxFailures, scala.concurrent.duration.FiniteDuration callTimeout, scala.concurrent.duration.FiniteDuration resetTimeout)
Callbacks run in caller's thread when using withSyncCircuitBreaker, and in same ExecutionContext as the passed in Future when using withCircuitBreaker. To use another ExecutionContext for the callbacks you can specify the executor in the constructor.
scheduler
- Reference to Akka schedulermaxFailures
- Maximum number of failures before opening the circuitcallTimeout
- FiniteDuration
of time after which to consider a call a failureresetTimeout
- FiniteDuration
of time after which to attempt to close the circuit
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |