Contents

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 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

17 entries across 17 versions & 1 rubygems

Version	Path
dispatch-rider-1.3.4	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.3.3	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.3.2	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.3.1	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.3.0	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.2.11	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.2.10	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.2.9	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.2.8	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.2.7	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.2.6	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.2.5	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.2.4	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.2.3	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.2.2	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.2.1	lib/dispatch-rider/queue_services/received_message.rb
dispatch-rider-1.2.0	lib/dispatch-rider/queue_services/received_message.rb