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