Sha256: 5d1705b3a2d69db8eb134d439b9dcf61aba2af33ba20e280d2b344fcccdb7038
Contents?: true
Size: 582 Bytes
Versions: 8
Compression:
Stored size: 582 Bytes
Contents
module FrenzyBunnies module Handlers class Oneshot def initialize(channel, queue, logger, opts) @channel = channel @opts = opts @logger = logger end def acknowledge(hdr, msg) @channel.acknowledge(hdr.delivery_tag, false) end def reject(hdr, msg, requeue=false) @channel.reject(hdr.delivery_tag, requeue) end def error(hdr, msg, err) reject(hdr, msg) end def timeout(hdr, msg) reject(hdr, msg) end def noop(hdr, msg) end end end end
Version data entries
8 entries across 8 versions & 1 rubygems