class DispatchRider::QueueServices::FileSystem
Public Instance Methods
assign_storage(attrs)
click to toggle source
# File lib/dispatch-rider/queue_services/file_system.rb, line 10 def assign_storage(attrs) begin path = attrs.fetch(:path) Queue.new(path) rescue IndexError raise RecordInvalid.new(self, ["Path can not be blank"]) end end
construct_message_from(item)
click to toggle source
# File lib/dispatch-rider/queue_services/file_system.rb, line 31 def construct_message_from(item) deserialize(item.read) end
delete(item)
click to toggle source
# File lib/dispatch-rider/queue_services/file_system.rb, line 39 def delete(item) queue.remove item end
insert(item)
click to toggle source
# File lib/dispatch-rider/queue_services/file_system.rb, line 19 def insert(item) queue.add item end
put_back(item)
click to toggle source
# File lib/dispatch-rider/queue_services/file_system.rb, line 35 def put_back(item) queue.put_back(item) end
raw_head()
click to toggle source
# File lib/dispatch-rider/queue_services/file_system.rb, line 23 def raw_head queue.pop end
received_message_for(raw_item)
click to toggle source
# File lib/dispatch-rider/queue_services/file_system.rb, line 27 def received_message_for(raw_item) FsReceivedMessage.new(construct_message_from(raw_item), raw_item, queue) end
size()
click to toggle source
# File lib/dispatch-rider/queue_services/file_system.rb, line 43 def size queue.size end