Sha256: 4e53f36eea8e873587ca76a78141d0cff645f0213b6e16d954f9a81ef0e3985c
Contents?: true
Size: 746 Bytes
Versions: 39
Compression:
Stored size: 746 Bytes
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