Class
Skynet::MessageQueueAdapter
In:
lib/skynet/message_queue_adapters/message_queue_adapter.rb
lib/skynet/message_queue_adapters/tuple_space.rb
Parent:
Object
Methods
clear_outstanding_tasks
get_worker_version
list_results
list_tasks
read_all_worker_statuses
set_worker_version
take_next_task
take_result
take_worker_status
write_error
write_message
write_result
write_worker_status
Classes and Modules
Class
Skynet::MessageQueueAdapter::Mysql
Class
Skynet::MessageQueueAdapter::TupleSpace
Public Instance methods
clear_outstanding_tasks
()
get_worker_version
(template,timeout=nil)
list_results
(data,timeout=nil)
list_tasks
(template,timeout=nil)
read_all_worker_statuses
(template,timeout=nil)
set_worker_version
(template,timeout=nil)
take_next_task
(template,timeout=nil)
take_result
(template,timeout=nil)
take_worker_status
(template,timeout=nil)
write_error
(template,timeout=nil)
write_message
(template,timeout=nil)
write_result
(template,timeout=nil)
write_worker_status
(template,timeout=nil)
[Validate]