Class: BanterWorker

Inherits:
Object
  • Object
show all
Includes:
Mongoid::Document
Defined in:
lib/banter/web/models/banter_worker.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.clear_current_message!(success = true) ⇒ Object

Clears the current message key for the worker

Parameters:

  • success (Boolean) (defaults to: true) —

    Indicate whether the job was successful or not



53
54
55
56
57
58
59
60
61
62
 
# File 'lib/banter/web/models/banter_worker.rb', line 53

def self.clear_current_message!(success = true)
  current.current_message = nil
  current.job_count += 1
  if success
    current.success_count += 1
  else
    current.failed_count += 1
  end
  current.save!
end

.record_current!(banter_message) ⇒ Object

Parameters:

  • banter_message (BanterMessage) —

    Message that is currently being executed



46
47
48
49
 
# File 'lib/banter/web/models/banter_worker.rb', line 46

def self.record_current!(banter_message)
  current.current_message = banter_message.attributes
  current.save!
end

.subscribers ⇒ Array

Returns Unique subscriber classes.

Returns:

  • (Array) —

    Unique subscriber classes



41
42
43
 
# File 'lib/banter/web/models/banter_worker.rb', line 41

def self.subscribers
  distinct("worker_classes")
end

.worker_started ⇒ Object

Parameters:

  • process_name (String)
  • process_pid (String)
  • hostname (String)
  • workers (Array(Subscriber)) —

    The subscriber classes that are being started by this worker



23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/banter/web/models/banter_worker.rb', line 23

def self.worker_started
  server_instance = Banter::Server::SubscriberServer.instance
  worker = new(process_name:   server_instance.process_name,
               pid:            server_instance.pid,
               hostname:       server_instance.hostname,
               started_at:     Time.now,
               worker_classes: Array.wrap(server_instance.workers).map(&:worker_class).map(&:name))
  worker.save!
  @@current = worker
  worker
end

.worker_stopped ⇒ Object 



35
36
37
38
 
# File 'lib/banter/web/models/banter_worker.rb', line 35

def self.worker_stopped
  current.try(:stop!)
  @@current = nil
end

Instance Method Details

#executing? ⇒ Boolean

Returns:

  • (Boolean) 


64
65
66
 
# File 'lib/banter/web/models/banter_worker.rb', line 64

def executing?
  current_message.present?
end

#stop! ⇒ Object 



68
69
70
71
 
# File 'lib/banter/web/models/banter_worker.rb', line 68

def stop!
  self.stopped_at = Time.now
  save!
end