lib/game-queue.rb in game-queue-0.2.3 vs lib/game-queue.rb in game-queue-0.2.4

@@ -20,11 +20,11 @@
 
   # ==== Parameters
   # message_name<String>: тип сообщения
   # message_body<Object>:: любой ruby объект с простыми данными, хэш, массив, число, строка...
   def push(message_name, message_body)
-    $redis.lpush(queue_name, Marshal.dump([message_name.to_s, message_body]))
+    redis.lpush(queue_name, Marshal.dump([message_name.to_s, message_body]))
   end
 
   # См. push
   def async_push(*params)
     Thread.new { push *params }
@@ -32,16 +32,16 @@
 
 
   # ==== Returns
   # <Array[String, Object]>::
   def pop
-    result = $redis.rpop(queue_name)
+    result = redis.rpop(queue_name)
     Marshal.load(result) if result
   end
 
   # ==== Description
   # очищает всю очередь
   def clean!
-    $redis.del(queue_name)
+    redis.del(queue_name)
   end
 
 end