core/camel-core-engine/src/main/java/org/apache/camel/model/Resilience4jConfigurationCommon.java - camel - Git at Google

 /*
  * Licensed to the Apache Software Foundation (ASF) under one or more
  * contributor license agreements.  See the NOTICE file distributed with
  * this work for additional information regarding copyright ownership.
  * The ASF licenses this file to You under the Apache License, Version 2.0
  * (the "License"); you may not use this file except in compliance with
  * the License.  You may obtain a copy of the License at
  *
  *      http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 package org.apache.camel.model;

 import java.util.concurrent.ForkJoinPool;
 import javax.xml.bind.annotation.XmlAccessType;
 import javax.xml.bind.annotation.XmlAccessorType;
 import javax.xml.bind.annotation.XmlAttribute;

 import org.apache.camel.spi.Metadata;

 @XmlAccessorType(XmlAccessType.FIELD)
 public class Resilience4jConfigurationCommon extends IdentifiedType {

     @XmlAttribute
     @Metadata(label = "circuitbreaker")
     private String circuitBreakerRef;
     @XmlAttribute
     @Metadata(label = "circuitbreaker")
     private String configRef;
     @XmlAttribute
     @Metadata(label = "circuitbreaker", defaultValue = "50")
     private Float failureRateThreshold;
     @XmlAttribute
     @Metadata(label = "circuitbreaker", defaultValue = "10")
     private Integer permittedNumberOfCallsInHalfOpenState;
     @XmlAttribute
     @Metadata(label = "circuitbreaker", defaultValue = "100")
     private Integer slidingWindowSize;
     @XmlAttribute
     @Metadata(label = "circuitbreaker", defaultValue = "COUNT_BASED", enums = "TIME_BASED,COUNT_BASED")
     private String slidingWindowType;
     @XmlAttribute
     @Metadata(label = "circuitbreaker", defaultValue = "100")
     private Integer minimumNumberOfCalls;
     @XmlAttribute
     @Metadata(label = "circuitbreaker", defaultValue = "true")
     private Boolean writableStackTraceEnabled;
     @XmlAttribute
     @Metadata(label = "circuitbreaker", defaultValue = "60")
     private Integer waitDurationInOpenState;
     @XmlAttribute
     @Metadata(label = "circuitbreaker", defaultValue = "false")
     private Boolean automaticTransitionFromOpenToHalfOpenEnabled;
     @XmlAttribute
     @Metadata(label = "circuitbreaker", defaultValue = "100")
     private Float slowCallRateThreshold;
     @XmlAttribute
     @Metadata(label = "circuitbreaker", defaultValue = "60")
     private Integer slowCallDurationThreshold;
     @Metadata(label = "bulkhead", defaultValue = "false")
     private Boolean bulkheadEnabled;
     @Metadata(label = "bulkhead", defaultValue = "25")
     private Integer bulkheadMaxConcurrentCalls;
     @Metadata(label = "bulkhead", defaultValue = "0")
     private Integer bulkheadMaxWaitDuration;
     @Metadata(label = "timeout", defaultValue = "false")
     private Boolean timeoutEnabled;
     @Metadata(label = "timeout")
     private String timeoutExecutorServiceRef;
     @Metadata(label = "timeout", defaultValue = "1000")
     private Integer timeoutDuration;
     @Metadata(label = "timeout", defaultValue = "true")
     private Boolean timeoutCancelRunningFuture;

     // Getter/Setter
     // -------------------------------------------------------------------------

     public String getCircuitBreakerRef() {
         return circuitBreakerRef;
     }

     /**
      * Refers to an existing io.github.resilience4j.circuitbreaker.CircuitBreaker instance
      * to lookup and use from the registry. When using this, then any other circuit breaker options
      * are not in use.
      */
     public void setCircuitBreakerRef(String circuitBreakerRef) {
         this.circuitBreakerRef = circuitBreakerRef;
     }

     public String getConfigRef() {
         return configRef;
     }

     /**
      * Refers to an existing io.github.resilience4j.circuitbreaker.CircuitBreakerConfig instance
      * to lookup and use from the registry.
      */
     public void setConfigRef(String configRef) {
         this.configRef = configRef;
     }

     public Float getFailureRateThreshold() {
         return failureRateThreshold;
     }

     /**
      * Configures the failure rate threshold in percentage.
      * If the failure rate is equal or greater than the threshold the CircuitBreaker transitions to open and starts short-circuiting calls.
      * <p>
      * The threshold must be greater than 0 and not greater than 100. Default value is 50 percentage.
      */
     public void setFailureRateThreshold(Float failureRateThreshold) {
         this.failureRateThreshold = failureRateThreshold;
     }

     public Integer getPermittedNumberOfCallsInHalfOpenState() {
         return permittedNumberOfCallsInHalfOpenState;
     }

     /**
      * Configures the number of permitted calls when the CircuitBreaker is half open.
      * <p>
      * The size must be greater than 0. Default size is 10.
      */
     public void setPermittedNumberOfCallsInHalfOpenState(Integer permittedNumberOfCallsInHalfOpenState) {
         this.permittedNumberOfCallsInHalfOpenState = permittedNumberOfCallsInHalfOpenState;
     }

     public Integer getSlidingWindowSize() {
         return slidingWindowSize;
     }

     /**
      * Configures the size of the sliding window which is used to record the outcome of calls when the CircuitBreaker is closed.
      * {@code slidingWindowSize} configures the size of the sliding window. Sliding window can either be count-based or time-based.
      *
      * If {@code slidingWindowType} is COUNT_BASED, the last {@code slidingWindowSize} calls are recorded and aggregated.
      * If {@code slidingWindowType} is TIME_BASED, the calls of the last {@code slidingWindowSize} seconds are recorded and aggregated.
      * <p>
      * The {@code slidingWindowSize} must be greater than 0.
      * The {@code minimumNumberOfCalls} must be greater than 0.
      * If the slidingWindowType is COUNT_BASED, the {@code minimumNumberOfCalls} cannot be greater than {@code slidingWindowSize}.
      * If the slidingWindowType is TIME_BASED, you can pick whatever you want.
      *
      * Default slidingWindowSize is 100.
      */
     public void setSlidingWindowSize(Integer slidingWindowSize) {
         this.slidingWindowSize = slidingWindowSize;
     }

     public String getSlidingWindowType() {
         return slidingWindowType;
     }

     /**
      * Configures the type of the sliding window which is used to record the outcome of calls when the CircuitBreaker is closed.
      * Sliding window can either be count-based or time-based.
      *
      * If {@code slidingWindowType} is COUNT_BASED, the last {@code slidingWindowSize} calls are recorded and aggregated.
      * If {@code slidingWindowType} is TIME_BASED, the calls of the last {@code slidingWindowSize} seconds are recorded and aggregated.
      *
      * Default slidingWindowType is COUNT_BASED.
      */
     public void setSlidingWindowType(String slidingWindowType) {
         this.slidingWindowType = slidingWindowType;
     }

     public Integer getMinimumNumberOfCalls() {
         return minimumNumberOfCalls;
     }

     /**
      * Configures configures the minimum number of calls which are required (per sliding window period) before the CircuitBreaker can calculate the error rate.
      * For example, if {@code minimumNumberOfCalls} is 10, then at least 10 calls must be recorded, before the failure rate can be calculated.
      * If only 9 calls have been recorded the CircuitBreaker will not transition to open even if all 9 calls have failed.
      *
      * Default minimumNumberOfCalls is 100
      */
     public void setMinimumNumberOfCalls(Integer minimumNumberOfCalls) {
         this.minimumNumberOfCalls = minimumNumberOfCalls;
     }

     public Boolean getWritableStackTraceEnabled() {
         return writableStackTraceEnabled;
     }

     /**
      * Enables writable stack traces. When set to false, Exception.getStackTrace returns a zero length array.
      * This may be used to reduce log spam when the circuit breaker is open as the cause of the exceptions is already known (the circuit breaker is short-circuiting calls).
      */
     public void setWritableStackTraceEnabled(Boolean writableStackTraceEnabled) {
         this.writableStackTraceEnabled = writableStackTraceEnabled;
     }

     public Integer getWaitDurationInOpenState() {
         return waitDurationInOpenState;
     }

     /**
      * Configures the wait duration (in seconds) which specifies how long the CircuitBreaker should stay open, before it switches to half open.
      * Default value is 60 seconds.
      */
     public void setWaitDurationInOpenState(Integer waitDurationInOpenState) {
         this.waitDurationInOpenState = waitDurationInOpenState;
     }

     public Boolean getAutomaticTransitionFromOpenToHalfOpenEnabled() {
         return automaticTransitionFromOpenToHalfOpenEnabled;
     }

     /**
      * Enables automatic transition from OPEN to HALF_OPEN state once the waitDurationInOpenState has passed.
      */
     public void setAutomaticTransitionFromOpenToHalfOpenEnabled(Boolean automaticTransitionFromOpenToHalfOpenEnabled) {
         this.automaticTransitionFromOpenToHalfOpenEnabled = automaticTransitionFromOpenToHalfOpenEnabled;
     }

     public Float getSlowCallRateThreshold() {
         return slowCallRateThreshold;
     }

     /**
      * Configures a threshold in percentage. The CircuitBreaker considers a call as slow when the call duration is greater than slowCallDurationThreshold(Duration.
      * When the percentage of slow calls is equal or greater the threshold, the CircuitBreaker transitions to open and starts short-circuiting calls.
      * <p>
      * The threshold must be greater than 0 and not greater than 100.
      * Default value is 100 percentage which means that all recorded calls must be slower than slowCallDurationThreshold.
      */
     public void setSlowCallRateThreshold(Float slowCallRateThreshold) {
         this.slowCallRateThreshold = slowCallRateThreshold;
     }

     public Integer getSlowCallDurationThreshold() {
         return slowCallDurationThreshold;
     }

     /**
      * Configures the duration threshold (seconds) above which calls are considered as slow and increase the slow calls percentage.
      * Default value is 60 seconds.
      */
     public void setSlowCallDurationThreshold(Integer slowCallDurationThreshold) {
         this.slowCallDurationThreshold = slowCallDurationThreshold;
     }

     public Boolean getBulkheadEnabled() {
         return bulkheadEnabled;
     }

     /**
      * Whether bulkhead is enabled or not on the circuit breaker.
      * Default is false.
      */
     public void setBulkheadEnabled(Boolean bulkheadEnabled) {
         this.bulkheadEnabled = bulkheadEnabled;
     }

     public Integer getBulkheadMaxConcurrentCalls() {
         return bulkheadMaxConcurrentCalls;
     }

     /**
      * Configures the max amount of concurrent calls the bulkhead will support.
      */
     public void setBulkheadMaxConcurrentCalls(Integer bulkheadMaxConcurrentCalls) {
         this.bulkheadMaxConcurrentCalls = bulkheadMaxConcurrentCalls;
     }

     public Integer getBulkheadMaxWaitDuration() {
         return bulkheadMaxWaitDuration;
     }

     /**
      * Configures a maximum amount of time which the calling thread will wait to enter the bulkhead. If bulkhead has space available, entry
      * is guaranteed and immediate. If bulkhead is full, calling threads will contest for space, if it becomes available. maxWaitDuration can be set to 0.
      * <p>
      * Note: for threads running on an event-loop or equivalent (rx computation pool, etc), setting maxWaitDuration to 0 is highly recommended. Blocking
      * an event-loop thread will most likely have a negative effect on application throughput.
      */
     public void setBulkheadMaxWaitDuration(Integer bulkheadMaxWaitDuration) {
         this.bulkheadMaxWaitDuration = bulkheadMaxWaitDuration;
     }

     public Boolean getTimeoutEnabled() {
         return timeoutEnabled;
     }

     /**
      * Whether timeout is enabled or not on the circuit breaker.
      * Default is false.
      */
     public void setTimeoutEnabled(Boolean timeoutEnabled) {
         this.timeoutEnabled = timeoutEnabled;
     }

     public String getTimeoutExecutorServiceRef() {
         return timeoutExecutorServiceRef;
     }

     /**
      * References to a custom thread pool to use when timeout is enabled (uses {@link ForkJoinPool#commonPool()} by default)
      */
     public void setTimeoutExecutorServiceRef(String timeoutExecutorServiceRef) {
         this.timeoutExecutorServiceRef = timeoutExecutorServiceRef;
     }

     public Integer getTimeoutDuration() {
         return timeoutDuration;
     }

     /**
      * Configures the thread execution timeout.
      * Default value is 1 second.
      */
     public void setTimeoutDuration(Integer timeoutDuration) {
         this.timeoutDuration = timeoutDuration;
     }

     public Boolean getTimeoutCancelRunningFuture() {
         return timeoutCancelRunningFuture;
     }

     /**
      * Configures whether cancel is called on the running future.
      * Defaults to true.
      */
     public void setTimeoutCancelRunningFuture(Boolean timeoutCancelRunningFuture) {
         this.timeoutCancelRunningFuture = timeoutCancelRunningFuture;
     }
 }
	/*
	* Licensed to the Apache Software Foundation (ASF) under one or more
	* contributor license agreements. See the NOTICE file distributed with
	* this work for additional information regarding copyright ownership.
	* The ASF licenses this file to You under the Apache License, Version 2.0
	* (the "License"); you may not use this file except in compliance with
	* the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/
	package org.apache.camel.model;

	import java.util.concurrent.ForkJoinPool;
	import javax.xml.bind.annotation.XmlAccessType;
	import javax.xml.bind.annotation.XmlAccessorType;
	import javax.xml.bind.annotation.XmlAttribute;

	import org.apache.camel.spi.Metadata;

	@XmlAccessorType(XmlAccessType.FIELD)
	public class Resilience4jConfigurationCommon extends IdentifiedType {

	@XmlAttribute
	@Metadata(label = "circuitbreaker")
	private String circuitBreakerRef;
	@XmlAttribute
	@Metadata(label = "circuitbreaker")
	private String configRef;
	@XmlAttribute
	@Metadata(label = "circuitbreaker", defaultValue = "50")
	private Float failureRateThreshold;
	@XmlAttribute
	@Metadata(label = "circuitbreaker", defaultValue = "10")
	private Integer permittedNumberOfCallsInHalfOpenState;
	@XmlAttribute
	@Metadata(label = "circuitbreaker", defaultValue = "100")
	private Integer slidingWindowSize;
	@XmlAttribute
	@Metadata(label = "circuitbreaker", defaultValue = "COUNT_BASED", enums = "TIME_BASED,COUNT_BASED")
	private String slidingWindowType;
	@XmlAttribute
	@Metadata(label = "circuitbreaker", defaultValue = "100")
	private Integer minimumNumberOfCalls;
	@XmlAttribute
	@Metadata(label = "circuitbreaker", defaultValue = "true")
	private Boolean writableStackTraceEnabled;
	@XmlAttribute
	@Metadata(label = "circuitbreaker", defaultValue = "60")
	private Integer waitDurationInOpenState;
	@XmlAttribute
	@Metadata(label = "circuitbreaker", defaultValue = "false")
	private Boolean automaticTransitionFromOpenToHalfOpenEnabled;
	@XmlAttribute
	@Metadata(label = "circuitbreaker", defaultValue = "100")
	private Float slowCallRateThreshold;
	@XmlAttribute
	@Metadata(label = "circuitbreaker", defaultValue = "60")
	private Integer slowCallDurationThreshold;
	@Metadata(label = "bulkhead", defaultValue = "false")
	private Boolean bulkheadEnabled;
	@Metadata(label = "bulkhead", defaultValue = "25")
	private Integer bulkheadMaxConcurrentCalls;
	@Metadata(label = "bulkhead", defaultValue = "0")
	private Integer bulkheadMaxWaitDuration;
	@Metadata(label = "timeout", defaultValue = "false")
	private Boolean timeoutEnabled;
	@Metadata(label = "timeout")
	private String timeoutExecutorServiceRef;
	@Metadata(label = "timeout", defaultValue = "1000")
	private Integer timeoutDuration;
	@Metadata(label = "timeout", defaultValue = "true")
	private Boolean timeoutCancelRunningFuture;

	// Getter/Setter
	// -------------------------------------------------------------------------

	public String getCircuitBreakerRef() {
	return circuitBreakerRef;
	}

	/**
	* Refers to an existing io.github.resilience4j.circuitbreaker.CircuitBreaker instance
	* to lookup and use from the registry. When using this, then any other circuit breaker options
	* are not in use.
	*/
	public void setCircuitBreakerRef(String circuitBreakerRef) {
	this.circuitBreakerRef = circuitBreakerRef;
	}

	public String getConfigRef() {
	return configRef;
	}

	/**
	* Refers to an existing io.github.resilience4j.circuitbreaker.CircuitBreakerConfig instance
	* to lookup and use from the registry.
	*/
	public void setConfigRef(String configRef) {
	this.configRef = configRef;
	}

	public Float getFailureRateThreshold() {
	return failureRateThreshold;
	}

	/**
	* Configures the failure rate threshold in percentage.
	* If the failure rate is equal or greater than the threshold the CircuitBreaker transitions to open and starts short-circuiting calls.
	* <p>
	* The threshold must be greater than 0 and not greater than 100. Default value is 50 percentage.
	*/
	public void setFailureRateThreshold(Float failureRateThreshold) {
	this.failureRateThreshold = failureRateThreshold;
	}

	public Integer getPermittedNumberOfCallsInHalfOpenState() {
	return permittedNumberOfCallsInHalfOpenState;
	}

	/**
	* Configures the number of permitted calls when the CircuitBreaker is half open.
	* <p>
	* The size must be greater than 0. Default size is 10.
	*/
	public void setPermittedNumberOfCallsInHalfOpenState(Integer permittedNumberOfCallsInHalfOpenState) {
	this.permittedNumberOfCallsInHalfOpenState = permittedNumberOfCallsInHalfOpenState;
	}

	public Integer getSlidingWindowSize() {
	return slidingWindowSize;
	}

	/**
	* Configures the size of the sliding window which is used to record the outcome of calls when the CircuitBreaker is closed.
	* {@code slidingWindowSize} configures the size of the sliding window. Sliding window can either be count-based or time-based.
	*
	* If {@code slidingWindowType} is COUNT_BASED, the last {@code slidingWindowSize} calls are recorded and aggregated.
	* If {@code slidingWindowType} is TIME_BASED, the calls of the last {@code slidingWindowSize} seconds are recorded and aggregated.
	* <p>
	* The {@code slidingWindowSize} must be greater than 0.
	* The {@code minimumNumberOfCalls} must be greater than 0.
	* If the slidingWindowType is COUNT_BASED, the {@code minimumNumberOfCalls} cannot be greater than {@code slidingWindowSize}.
	* If the slidingWindowType is TIME_BASED, you can pick whatever you want.
	*
	* Default slidingWindowSize is 100.
	*/
	public void setSlidingWindowSize(Integer slidingWindowSize) {
	this.slidingWindowSize = slidingWindowSize;
	}

	public String getSlidingWindowType() {
	return slidingWindowType;
	}

	/**
	* Configures the type of the sliding window which is used to record the outcome of calls when the CircuitBreaker is closed.
	* Sliding window can either be count-based or time-based.
	*
	* If {@code slidingWindowType} is COUNT_BASED, the last {@code slidingWindowSize} calls are recorded and aggregated.
	* If {@code slidingWindowType} is TIME_BASED, the calls of the last {@code slidingWindowSize} seconds are recorded and aggregated.
	*
	* Default slidingWindowType is COUNT_BASED.
	*/
	public void setSlidingWindowType(String slidingWindowType) {
	this.slidingWindowType = slidingWindowType;
	}

	public Integer getMinimumNumberOfCalls() {
	return minimumNumberOfCalls;
	}

	/**
	* Configures configures the minimum number of calls which are required (per sliding window period) before the CircuitBreaker can calculate the error rate.
	* For example, if {@code minimumNumberOfCalls} is 10, then at least 10 calls must be recorded, before the failure rate can be calculated.
	* If only 9 calls have been recorded the CircuitBreaker will not transition to open even if all 9 calls have failed.
	*
	* Default minimumNumberOfCalls is 100
	*/
	public void setMinimumNumberOfCalls(Integer minimumNumberOfCalls) {
	this.minimumNumberOfCalls = minimumNumberOfCalls;
	}

	public Boolean getWritableStackTraceEnabled() {
	return writableStackTraceEnabled;
	}

	/**
	* Enables writable stack traces. When set to false, Exception.getStackTrace returns a zero length array.
	* This may be used to reduce log spam when the circuit breaker is open as the cause of the exceptions is already known (the circuit breaker is short-circuiting calls).
	*/
	public void setWritableStackTraceEnabled(Boolean writableStackTraceEnabled) {
	this.writableStackTraceEnabled = writableStackTraceEnabled;
	}

	public Integer getWaitDurationInOpenState() {
	return waitDurationInOpenState;
	}

	/**
	* Configures the wait duration (in seconds) which specifies how long the CircuitBreaker should stay open, before it switches to half open.
	* Default value is 60 seconds.
	*/
	public void setWaitDurationInOpenState(Integer waitDurationInOpenState) {
	this.waitDurationInOpenState = waitDurationInOpenState;
	}

	public Boolean getAutomaticTransitionFromOpenToHalfOpenEnabled() {
	return automaticTransitionFromOpenToHalfOpenEnabled;
	}

	/**
	* Enables automatic transition from OPEN to HALF_OPEN state once the waitDurationInOpenState has passed.
	*/
	public void setAutomaticTransitionFromOpenToHalfOpenEnabled(Boolean automaticTransitionFromOpenToHalfOpenEnabled) {
	this.automaticTransitionFromOpenToHalfOpenEnabled = automaticTransitionFromOpenToHalfOpenEnabled;
	}

	public Float getSlowCallRateThreshold() {
	return slowCallRateThreshold;
	}

	/**
	* Configures a threshold in percentage. The CircuitBreaker considers a call as slow when the call duration is greater than slowCallDurationThreshold(Duration.
	* When the percentage of slow calls is equal or greater the threshold, the CircuitBreaker transitions to open and starts short-circuiting calls.
	* <p>
	* The threshold must be greater than 0 and not greater than 100.
	* Default value is 100 percentage which means that all recorded calls must be slower than slowCallDurationThreshold.
	*/
	public void setSlowCallRateThreshold(Float slowCallRateThreshold) {
	this.slowCallRateThreshold = slowCallRateThreshold;
	}

	public Integer getSlowCallDurationThreshold() {
	return slowCallDurationThreshold;
	}

	/**
	* Configures the duration threshold (seconds) above which calls are considered as slow and increase the slow calls percentage.
	* Default value is 60 seconds.
	*/
	public void setSlowCallDurationThreshold(Integer slowCallDurationThreshold) {
	this.slowCallDurationThreshold = slowCallDurationThreshold;
	}

	public Boolean getBulkheadEnabled() {
	return bulkheadEnabled;
	}

	/**
	* Whether bulkhead is enabled or not on the circuit breaker.
	* Default is false.
	*/
	public void setBulkheadEnabled(Boolean bulkheadEnabled) {
	this.bulkheadEnabled = bulkheadEnabled;
	}

	public Integer getBulkheadMaxConcurrentCalls() {
	return bulkheadMaxConcurrentCalls;
	}

	/**
	* Configures the max amount of concurrent calls the bulkhead will support.
	*/
	public void setBulkheadMaxConcurrentCalls(Integer bulkheadMaxConcurrentCalls) {
	this.bulkheadMaxConcurrentCalls = bulkheadMaxConcurrentCalls;
	}

	public Integer getBulkheadMaxWaitDuration() {
	return bulkheadMaxWaitDuration;
	}

	/**
	* Configures a maximum amount of time which the calling thread will wait to enter the bulkhead. If bulkhead has space available, entry
	* is guaranteed and immediate. If bulkhead is full, calling threads will contest for space, if it becomes available. maxWaitDuration can be set to 0.
	* <p>
	* Note: for threads running on an event-loop or equivalent (rx computation pool, etc), setting maxWaitDuration to 0 is highly recommended. Blocking
	* an event-loop thread will most likely have a negative effect on application throughput.
	*/
	public void setBulkheadMaxWaitDuration(Integer bulkheadMaxWaitDuration) {
	this.bulkheadMaxWaitDuration = bulkheadMaxWaitDuration;
	}

	public Boolean getTimeoutEnabled() {
	return timeoutEnabled;
	}

	/**
	* Whether timeout is enabled or not on the circuit breaker.
	* Default is false.
	*/
	public void setTimeoutEnabled(Boolean timeoutEnabled) {
	this.timeoutEnabled = timeoutEnabled;
	}

	public String getTimeoutExecutorServiceRef() {
	return timeoutExecutorServiceRef;
	}

	/**
	* References to a custom thread pool to use when timeout is enabled (uses {@link ForkJoinPool#commonPool()} by default)
	*/
	public void setTimeoutExecutorServiceRef(String timeoutExecutorServiceRef) {
	this.timeoutExecutorServiceRef = timeoutExecutorServiceRef;
	}

	public Integer getTimeoutDuration() {
	return timeoutDuration;
	}

	/**
	* Configures the thread execution timeout.
	* Default value is 1 second.
	*/
	public void setTimeoutDuration(Integer timeoutDuration) {
	this.timeoutDuration = timeoutDuration;
	}

	public Boolean getTimeoutCancelRunningFuture() {
	return timeoutCancelRunningFuture;
	}

	/**
	* Configures whether cancel is called on the running future.
	* Defaults to true.
	*/
	public void setTimeoutCancelRunningFuture(Boolean timeoutCancelRunningFuture) {
	this.timeoutCancelRunningFuture = timeoutCancelRunningFuture;
	}
	}