Module: Hsdq::Admin

Included in:
Hsdq
Defined in:
lib/hsdq/admin.rb

Instance Method Summary collapse

Instance Method Details

#admin_channel ⇒ Object 



14
15
16
 
# File 'lib/hsdq/admin.rb', line 14

def admin_channel
  "#{environment}_#{channel}_admin"
end

#admin_channels ⇒ Object 



26
27
28
 
# File 'lib/hsdq/admin.rb', line 26

def admin_channels
  @admin_channels ||= %w(admin )
end

#admin_id_channel ⇒ Object 



22
23
24
 
# File 'lib/hsdq/admin.rb', line 22

def admin_id_channel
  "#{admin_channel}__#{listener_id}"
end

#admin_listener ⇒ Object 



30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/hsdq/admin.rb', line 30

def admin_listener
  begin
    p "starting admin channels #{admin_channel}, #{admin_versionned_channel}"
    cx_admin.subscribe(admin_channel, admin_versionned_channel) do |on|
      on.message do |a_channel, admin_message_j|
        p "received admin message: #{admin_message_j} from admin channel #{admin_channel} "
        process_admin_message(admin_channel, admin_message_j)
      end
    end
  rescue Redis::BaseConnectionError => e
    p e.inspect
    sleep(1)
    retry
  end
end

#admin_versionned_channel ⇒ Object 



18
19
20
 
# File 'lib/hsdq/admin.rb', line 18

def admin_versionned_channel
  "#{admin_channel}__#{listener_version}"
end

#listener_id(listener_id = nil) ⇒ Object 



4
5
6
7
 
# File 'lib/hsdq/admin.rb', line 4

def listener_id(listener_id=nil)
  @listener_id = listener_id if listener_id
  @listener_id
end

#listener_version(listener_version = nil) ⇒ Object 



9
10
11
12
 
# File 'lib/hsdq/admin.rb', line 9

def listener_version(listener_version=nil)
  @listener_version = listener_version if listener_version
  @listener_version
end

#process_admin_message(_admin_channel, admin_message_j) ⇒ Object 



46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/hsdq/admin.rb', line 46

def process_admin_message(_admin_channel, admin_message_j)
  admin_message = JSON.parse(admin_message_j) rescue {'params' => {'task' => ""}}
  task = admin_message['params'] ? admin_message['params']['task'] : ""
  case task
    when 'stop'
      hsdq_stop!
    when 'start'
      hsdq_start!
    when 'exit'
      hsdq_exit!
  end
end