Class: Skynet::MessageQueueAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/skynet/message_queue_adapters/message_queue_adapter.rb,
lib/skynet/message_queue_adapters/tuple_space.rb

Direct Known Subclasses

MessageQueueAdapter::Mysql, TupleSpace

Defined Under Namespace

Classes: Mysql, TupleSpace

Instance Method Summary collapse

Instance Method Details

#clear_outstanding_tasks ⇒ Object

Raises:



65
66
67
 
# File 'lib/skynet/message_queue_adapters/message_queue_adapter.rb', line 65

def clear_outstanding_tasks
  raise AbstractClassError.new("You must implement clear_outstanding_tasks in a subclass.")
end

#get_worker_version(template, timeout = nil) ⇒ Object

Raises:



57
58
59
 
# File 'lib/skynet/message_queue_adapters/message_queue_adapter.rb', line 57

def get_worker_version(template,timeout=nil)
  raise AbstractClassError.new("You must implement method in a subclass.")
end

#list_results(data, timeout = nil) ⇒ Object

Raises:



17
18
19
 
# File 'lib/skynet/message_queue_adapters/message_queue_adapter.rb', line 17

def list_results(data,timeout=nil)
  raise AbstractClassError.new("You must implement list_results in a subclass.")
end

#list_tasks(template, timeout = nil) ⇒ Object

Raises:



21
22
23
 
# File 'lib/skynet/message_queue_adapters/message_queue_adapter.rb', line 21

def list_tasks(template,timeout=nil)
  raise AbstractClassError.new("You must implement method in a subclass.")
end

#read_all_worker_statuses(template, timeout = nil) ⇒ Object

Raises:



53
54
55
 
# File 'lib/skynet/message_queue_adapters/message_queue_adapter.rb', line 53

def read_all_worker_statuses(template,timeout=nil)
  raise AbstractClassError.new("You must implement method in a subclass.")
end

#set_worker_version(template, timeout = nil) ⇒ Object

Raises:



61
62
63
 
# File 'lib/skynet/message_queue_adapters/message_queue_adapter.rb', line 61

def set_worker_version(template,timeout=nil)
  raise AbstractClassError.new("You must implement method in a subclass.")
end

#take_next_task(template, timeout = nil) ⇒ Object

Raises:



25
26
27
 
# File 'lib/skynet/message_queue_adapters/message_queue_adapter.rb', line 25

def take_next_task(template,timeout=nil)
  raise AbstractClassError.new("You must implement method in a subclass.")
end

#take_result(template, timeout = nil) ⇒ Object

Raises:



37
38
39
 
# File 'lib/skynet/message_queue_adapters/message_queue_adapter.rb', line 37

def take_result(template,timeout=nil)
  raise AbstractClassError.new("You must implement method in a subclass.")
end

#take_worker_status(template, timeout = nil) ⇒ Object

Raises:



49
50
51
 
# File 'lib/skynet/message_queue_adapters/message_queue_adapter.rb', line 49

def take_worker_status(template,timeout=nil)
  raise AbstractClassError.new("You must implement method in a subclass.")
end

#write_error(template, timeout = nil) ⇒ Object

Raises:



41
42
43
 
# File 'lib/skynet/message_queue_adapters/message_queue_adapter.rb', line 41

def write_error(template,timeout=nil)
  raise AbstractClassError.new("You must implement method in a subclass.")
end

#write_message(template, timeout = nil) ⇒ Object

Raises:



29
30
31
 
# File 'lib/skynet/message_queue_adapters/message_queue_adapter.rb', line 29

def write_message(template,timeout=nil)
  raise AbstractClassError.new("You must implement method in a subclass.")
end

#write_result(template, timeout = nil) ⇒ Object

Raises:



33
34
35
 
# File 'lib/skynet/message_queue_adapters/message_queue_adapter.rb', line 33

def write_result(template,timeout=nil)
  raise AbstractClassError.new("You must implement method in a subclass.")
end

#write_worker_status(template, timeout = nil) ⇒ Object

Raises:



45
46
47
 
# File 'lib/skynet/message_queue_adapters/message_queue_adapter.rb', line 45

def write_worker_status(template,timeout=nil)
  raise AbstractClassError.new("You must implement method in a subclass.")
end