Contents

module DispatchRider
  module QueueServices
    class FileSystem < Base
      class FsReceivedMessage < ReceivedMessage
        attr_reader :queue
        
        def initialize(message, item, queue)
          @queue = queue
          super(message, item)
        end
        
        def extend_timeout(timeout)
          #file system doesn't support timeouts on items, so we ignore this.
        end
        
        def return_to_queue
          queue.put_back(item)
        end

        def receive_count
          1 # can't really check that in this service
        end

        def sent_at
          @item.ctime
        end

        def queue_name
          File.basename(File.dirname(@item.path))
        end

      end
    end
  end
end

Version data entries

39 entries across 39 versions & 1 rubygems

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