Package akka.pattern.internal

Class CircuitBreakerNoopTelemetry$

java.lang.Object

akka.pattern.internal.CircuitBreakerNoopTelemetry$

All Implemented Interfaces:

CircuitBreakerTelemetry

public class CircuitBreakerNoopTelemetry$
extends java.lang.Object
implements CircuitBreakerTelemetry

INTERNAL API

Field Summary

Fields

Modifier and Type	Field	Description
static CircuitBreakerNoopTelemetry$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
CircuitBreakerNoopTelemetry$()

Method Summary

Modifier and Type	Method	Description
void	onCallBreakerOpenFailure()	Invoked for each call when the future is completed with akka.pattern.CircuitBreakerOpenException
void	onCallFailure(long elapsedNanos)	Invoked for each call when the future is completed with exception, except for scala.concurrent.TimeoutException and CircuitBreakerOpenException that are handled by separate methods.
void	onCallSuccess(long elapsedNanos)	Invoked for each successful call.
void	onCallTimeoutFailure(long elapsedNanos)	Invoked for each call when the future is completed with java.util.concurrent.TimeoutException
void	onClose()	Invoked when the circuit breaker transitions to the close state.
void	onHalfOpen()	Invoked when the circuit breaker transitions to the half-open state after reset timeout.
void	onOpen()	Invoked when the circuit breaker transitions to the open state.
void	stopped()	Called when the circuit breaker is removed, e.g.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE$

public static final CircuitBreakerNoopTelemetry$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

CircuitBreakerNoopTelemetry$

public CircuitBreakerNoopTelemetry$()

Method Detail

onOpen

public void onOpen()

Description copied from interface: CircuitBreakerTelemetry

Invoked when the circuit breaker transitions to the open state.

Specified by:

onOpen in interface CircuitBreakerTelemetry

onClose

public void onClose()

Description copied from interface: CircuitBreakerTelemetry

Invoked when the circuit breaker transitions to the close state.

Specified by:

onClose in interface CircuitBreakerTelemetry

onHalfOpen

public void onHalfOpen()

Description copied from interface: CircuitBreakerTelemetry

Invoked when the circuit breaker transitions to the half-open state after reset timeout.

Specified by:

onHalfOpen in interface CircuitBreakerTelemetry

onCallSuccess

public void onCallSuccess(long elapsedNanos)

Description copied from interface: CircuitBreakerTelemetry

Invoked for each successful call.

Specified by:

onCallSuccess in interface CircuitBreakerTelemetry

Parameters:

elapsedNanos - the elapsed duration of the call in nanoseconds

onCallFailure

public void onCallFailure(long elapsedNanos)

Description copied from interface: CircuitBreakerTelemetry

Invoked for each call when the future is completed with exception, except for scala.concurrent.TimeoutException and CircuitBreakerOpenException that are handled by separate methods.

Specified by:

onCallFailure in interface CircuitBreakerTelemetry

Parameters:

elapsedNanos - the elapsed duration of the call in nanoseconds

onCallTimeoutFailure

public void onCallTimeoutFailure(long elapsedNanos)

Description copied from interface: CircuitBreakerTelemetry

Invoked for each call when the future is completed with java.util.concurrent.TimeoutException

Specified by:

onCallTimeoutFailure in interface CircuitBreakerTelemetry

Parameters:

elapsedNanos - the elapsed duration of the call in nanoseconds

onCallBreakerOpenFailure

public void onCallBreakerOpenFailure()

Description copied from interface: CircuitBreakerTelemetry

Invoked for each call when the future is completed with akka.pattern.CircuitBreakerOpenException

Specified by:

onCallBreakerOpenFailure in interface CircuitBreakerTelemetry

stopped

public void stopped()

Description copied from interface: CircuitBreakerTelemetry

Called when the circuit breaker is removed, e.g. expired due to inactivity. It is also called if the circuit breaker is re-configured, before calling CircuitBreakerTelemetryProvider.start(java.lang.String, akka.actor.ExtendedActorSystem).

Specified by:

stopped in interface CircuitBreakerTelemetry