Contents

module DispatchRider
  module QueueServices
    class AwsSqs < Base
      class SqsReceivedMessage < ReceivedMessage
        attr_reader :total_timeout, :start_time
        
        def initialize(message, raw_item, queue)
          @total_timeout = queue.visibility_timeout
          @start_time = Time.now
          super(message, raw_item)
        end
        
        # NOTE: Setting the visibility timeout resets the timeout to NOW and makes it visibility timeout this time
        # Essentially resetting the timer on this message
        def extend_timeout(timeout)
          item.visibility_timeout = timeout
          if timeout > 0
            @total_timeout = timeout + (Time.now - start_time).to_i
          end
        end
        
        # We effectively return the item to the queue by setting
        # the visibility timeout to zero.  The item
        # should become immediately visible.
        # The next receiver will reset the visibility
        # to something appropriate
        def return_to_queue
          extend_timeout(0)
        end
        
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
dispatch-rider-1.1.7	lib/dispatch-rider/queue_services/aws_sqs/sqs_received_message.rb
dispatch-rider-1.1.6	lib/dispatch-rider/queue_services/aws_sqs/sqs_received_message.rb
dispatch-rider-1.1.5	lib/dispatch-rider/queue_services/aws_sqs/sqs_received_message.rb
dispatch-rider-1.1.4	lib/dispatch-rider/queue_services/aws_sqs/sqs_received_message.rb