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 |