class DispatchRider::QueueServices::FileSystem::FsReceivedMessage
Attributes
queue[R]
Public Class Methods
new(message, item, queue)
click to toggle source
Calls superclass method
# File lib/dispatch-rider/queue_services/file_system/fs_received_message.rb, line 7 def initialize(message, item, queue) @queue = queue super(message, item) end
Public Instance Methods
extend_timeout(timeout)
click to toggle source
# File lib/dispatch-rider/queue_services/file_system/fs_received_message.rb, line 12 def extend_timeout(timeout) #file system doesn't support timeouts on items, so we ignore this. end
queue_name()
click to toggle source
# File lib/dispatch-rider/queue_services/file_system/fs_received_message.rb, line 28 def queue_name File.basename(File.dirname(@item.path)) end
receive_count()
click to toggle source
# File lib/dispatch-rider/queue_services/file_system/fs_received_message.rb, line 20 def receive_count 1 # can't really check that in this service end
return_to_queue()
click to toggle source
# File lib/dispatch-rider/queue_services/file_system/fs_received_message.rb, line 16 def return_to_queue queue.put_back(item) end
sent_at()
click to toggle source
# File lib/dispatch-rider/queue_services/file_system/fs_received_message.rb, line 24 def sent_at @item.ctime end