blob: 5743d5bbb50d1b4ad1a0c0021a5f77f808660338 (
plain) (
tree)
|
|
require 'queue_classic'
module QC
class Queue
def enqueue(method, *args)
receiver_str, _, message = method.rpartition('.')
receiver = eval(receiver_str)
receiver.send(message, *args)
end
def enqueue_in(seconds, method, *args)
receiver_str, _, message = method.rpartition('.')
receiver = eval(receiver_str)
receiver.send(message, *args)
end
def enqueue_at(not_before, method, *args)
receiver_str, _, message = method.rpartition('.')
receiver = eval(receiver_str)
receiver.send(message, *args)
end
end
end
|