Contents

module Workarea
  module CircuitBreakerSupport
    def with_connection_pool_timeouts(&block)
      @_original_pool = CircuitBreaker.redis
      timeout_pool = ConnectionPool.new(timeout: 0, size: 0) do
        Redis.new(url: Workarea::Configuration::Redis.persistent.to_url)
      end
      CircuitBreaker.instance_variable_set(:@redis, timeout_pool)

      block.call

    ensure
      CircuitBreaker.instance_variable_set(:@redis, @_original_pool)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
workarea-circuit_breaker-1.0.3	test/support/circuit_breaker_support.rb