lib/message_bus/backends/redis.rb in message_bus-2.2.2 vs lib/message_bus/backends/redis.rb in message_bus-2.2.3
- old
+ new
@@ -325,10 +325,10 @@
end
private
def new_redis_connection
- ::Redis.new(@redis_config)
+ ::Redis.new(@redis_config.dup)
end
# redis connection used for publishing messages
def pub_redis
@pub_redis ||= new_redis_connection