Sha256: dd861c7129d2eeb45a7d88f41f835e2a885518d36ad72ff97bd15ce93e4d672e
Contents?: true
Size: 796 Bytes
Versions: 1
Compression:
Stored size: 796 Bytes
Contents
# frozen_string_literal: true require 'delegate' module DispatchRider module QueueServices class ReceivedMessage < ::SimpleDelegator #Item is the raw message item as returned by the queue implementor #it's contents will depend on the queue being used attr_reader :item def initialize(message, item) @item = item super(message) end def guid body['guid'] end def extend_timeout(time) raise NotImplementedError end def return_to_queue raise NotImplementedError end def receive_count raise NotImplementedError end def sent_at raise NotImplementedError end def queue_name raise NotImplementedError end end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
dispatch-rider-2.2.0 | lib/dispatch-rider/queue_services/received_message.rb |