module SidekiqScheduler::Client

def delayed_push(queue=nil, timestamp, item)
  raise(ArgumentError, "Message must be a Hash of the form: { 'class' => SomeClass, 'args' => ['bob', 1, :foo => 'bar'] }") unless item.is_a?(Hash)
  raise(ArgumentError, "Message must include a class and set of arguments: #{item.inspect}") if !item['class'] || !item['args']
  timestamp = timestamp.to_i
  item['queue'] = queue.to_s if queue
  item['class'] = item['class'].to_s if !item['class'].is_a?(String)
  # Add item to the list for this timestamp
  Sidekiq.redis { |r| r.rpush("delayed:#{timestamp}", MultiJson.encode(item)) }
  # Add timestamp to zset. Score and value are based on the timestamp
  # as querying will be based on that
  Sidekiq.redis { |r| r.zadd('delayed_queue_schedule', timestamp, timestamp) }
end