Sha256: c5ecc0593d67b6f41dde75b18b82cbcb121eea52ec79db5ec06ce1c57df59e1a
Contents?: true
Size: 545 Bytes
Versions: 7
Compression:
Stored size: 545 Bytes
Contents
# This isn't a queue at all, it just writes to standard output.
#
# It might be useful for testing.
#
class JobQueue::VerboseAdapter
def initialize(options = {})
end
def put(string, queue, priority, ttr)
JobQueue.logger.debug "===== NEW JOB ADDED TO QUEUE ===="
JobQueue.logger.debug string
JobQueue.logger.debug "===== END OF MESSAGE ============"
end
def subscribe(error_report, &block)
raise "Not implemented. Use a better adapter!!"
end
def queue_length(queue)
raise "Not supported"
end
end
Version data entries
7 entries across 7 versions & 2 rubygems