lib/skynet/skynet_message.rb in skynet-0.9.2 vs lib/skynet/skynet_message.rb in skynet-0.9.3
- old
+ new
@@ -308,10 +308,11 @@
end
end
end
class WorkerStatusMessage < Skynet::Message
+# I'd love to rename tasktype and tasksubtype to something more reasonable
self.fields = [
:tasktype,
:tasksubtype,
:worker_id,
:hostname,
@@ -328,17 +329,15 @@
]
self.fields.each { |method| attr_accessor method }
def initialize(opts)
super
- self.tasktype = :status
self.tasksubtype = :worker
end
def self.worker_status_template(opts)
template = {
- :tasktype => :status,
:tasksubtype => :worker,
:hostname => opts[:hostname],
:process_id => opts[:process_id]
}
fields.collect do |field|
@@ -346,10 +345,9 @@
end
end
def self.all_workers_template(hostname=nil)
template = {
- :tasktype => :status,
:tasksubtype => :worker,
:hostname => hostname,
}
fields.collect do |field|
template[field]