sptz45 / sse-breaker Goto Github PK

Should be done after JMX

I am trying to integrate your library into my project and it seems like the circuit is not tripping to open state properly.

My application is making requests every 4 seconds to a MongoDB database and I am shutting down the DB while the application is running. If a start the application when the DB is down the breaker is tripped into Open state when the failure counter reaches the maxFailures count, then I start up the DB again and the breaker is tripped into the Close state properly but if I shutdown the DB one more time the breaker is not tripping to the Open state anymore.

See below my code:

circuitBreaker match {
      case Some(breaker) => {
        breaker.failFast (fetchData(theQuery, filters, fetchMetaData))
          .recover { case _: OpenCircuitException => {
              Logger.error(Messages("circuitbreaker.open.circuit.error", dataProviderProperties.prettyPrint()))
              Left(FailResult(Messages("circuitbreaker.open.circuit.error", dataProviderProperties.prettyPrint())))

          }}
      }
      case _ => {
        fetchData(theQuery, filters, fetchMetaData)
      }
    }

val failFast = new CircuitExecutor(
name="tweets-breaker",
CircuitConfiguration(
maxFailures = 5,
openCircuitTimeout = 30.seconds,
failureCountTimeout = 1.minute,
maxMethodDuration = 10.seconds)
)
Compile Error :

not enough arguments for constructor CircuitExecutor: (circuitName: String, circuitConfig: com.tzavellas.sse.breaker.CircuitConfiguration, circuitListener: com.tzavellas.sse.breaker.CircuitStateListener)com.tzavellas.sse.breaker.CircuitExecutor

This should be based on the sse-jmx project.