Sha256: dce23f3122399a1021dec779f86464c86ed71328b80b1555d43bdb835c68e114

Contents?: true

Size: 468 Bytes

Versions: 1

Compression:

Stored size: 468 Bytes

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