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