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.



7
8
9
10
 
# 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

Instance Attribute Details

#queue ⇒ Object (readonly)

Returns the value of attribute queue.



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

def queue
  @queue
end

Instance Method Details

#extend_timeout(timeout) ⇒ Object 



12
13
14
 
# 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 ⇒ Object 



28
29
30
 
# 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 ⇒ Object 



20
21
22
 
# 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 ⇒ Object 



16
17
18
 
# 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 ⇒ Object 



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

def sent_at
  @item.ctime
end