class Mercury::Fake::QueuedMessage
Attributes
delivered[RW]
headers[R]
received_msg[R]
subscriber[RW]
Public Class Methods
new(queue, msg, tag, headers, is_ackable)
click to toggle source
# File lib/mercury/fake/queued_message.rb, line 10 def initialize(queue, msg, tag, headers, is_ackable) metadata = Metadata.new(tag, headers, proc{queue.ack_or_reject_message(self)}, proc{queue.nack(self)}) @received_msg = ReceivedMessage.new(msg, metadata, nil, work_queue_name: is_ackable ? queue.worker : nil) @headers = headers @delivered = false end