Class: DispatchRider::QueueServices::FileSystem::FsReceivedMessage

Inherits:
ReceivedMessage
  • Object
show all
Defined in:
lib/dispatch-rider/queue_services/file_system/fs_received_message.rb

Instance Attribute Summary collapse

Attributes inherited from ReceivedMessage

#item

Instance Method Summary collapse

Methods inherited from ReceivedMessage

#guid

Constructor Details

#initialize(message, item, queue) ⇒ FsReceivedMessage

Returns a new instance of FsReceivedMessage.



9
10
11
12
 
# File 'lib/dispatch-rider/queue_services/file_system/fs_received_message.rb', line 9

def initialize(message, item, queue)
  @queue = queue
  super(message, item)
end

Instance Attribute Details

#queue ⇒ Object (readonly)

Returns the value of attribute queue.



7
8
9
 
# File 'lib/dispatch-rider/queue_services/file_system/fs_received_message.rb', line 7

def queue
  @queue
end

Instance Method Details

#extend_timeout(timeout) ⇒ Object 



14
15
16
 
# File 'lib/dispatch-rider/queue_services/file_system/fs_received_message.rb', line 14

def extend_timeout(timeout)
  #file system doesn't support timeouts on items, so we ignore this.
end

#queue_name ⇒ Object 



30
31
32
 
# File 'lib/dispatch-rider/queue_services/file_system/fs_received_message.rb', line 30

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

#receive_count ⇒ Object 



22
23
24
 
# File 'lib/dispatch-rider/queue_services/file_system/fs_received_message.rb', line 22

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

#return_to_queue ⇒ Object 



18
19
20
 
# File 'lib/dispatch-rider/queue_services/file_system/fs_received_message.rb', line 18

def return_to_queue
  queue.put_back(item)
end

#sent_at ⇒ Object 



26
27
28
 
# File 'lib/dispatch-rider/queue_services/file_system/fs_received_message.rb', line 26

def sent_at
  @item.ctime
end