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