Sha256: 5ff301dbbbbc513dd6ff6cd6ae89a4ac4e1d4c0fe95029dc0178c56b21719f52
Contents?: true
Size: 463 Bytes
Versions: 17
Compression:
Stored size: 463 Bytes
Contents
class Mercury
class Fake
class Metadata
attr_reader :headers
def initialize(tag, headers, dequeue, requeue)
@tag = tag
@dequeue = dequeue
@requeue = requeue
@headers = headers
end
def routing_key
@tag
end
def ack
@dequeue.call
end
def reject(opts)
requeue = opts[:requeue]
requeue ? @requeue.call : @dequeue.call
end
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems