Sha256: a3b92c4f67f2bf35a36b12b103d71deff7ffef5777b226f7b3a48457674a860d
Contents?: true
Size: 572 Bytes
Versions: 6
Compression:
Stored size: 572 Bytes
Contents
require 'mercury/fake/metadata'
require 'mercury/received_message'
class Mercury
class Fake
class QueuedMessage
attr_reader :received_msg, :headers
attr_accessor :delivered, :subscriber
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
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems