lib/game-queue.rb in game-queue-0.2.0 vs lib/game-queue.rb in game-queue-0.2.1

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