Skip to content

Commit 589bba3

Browse files
authored
Merge pull request #7 from remy727/redis-current-deprecation
Deprecate Redis.current
2 parents 08bfb31 + 33e5bff commit 589bba3

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

lib/redis/queue.rb

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,8 +12,9 @@ def initialize(queue_name, process_queue_name, options = {})
1212
raise ArgumentError, 'First argument must be a non empty string' if !queue_name.is_a?(String) || queue_name.empty?
1313
raise ArgumentError, 'Second argument must be a non empty string' if !process_queue_name.is_a?(String) || process_queue_name.empty?
1414
raise ArgumentError, 'Queue and Process queue have the same name' if process_queue_name == queue_name
15+
raise ArgumentError, 'Redis is required' if options[:redis].nil?
1516

16-
@redis = options[:redis] || Redis.current
17+
@redis = options[:redis]
1718
@queue_name = queue_name
1819
@process_queue_name = process_queue_name
1920
@last_message = nil

spec/redis_queue_spec.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
end
2020

2121
it 'should create a new redis-queue object' do
22-
queue = Redis::Queue.new('__test', 'bp__test')
22+
queue = Redis::Queue.new('__test', 'bp__test', redis: @redis)
2323
queue.class.should == Redis::Queue
2424
end
2525

0 commit comments

Comments
 (0)