Class: Localjob::CLI

Inherits:
Thor
  • Object
show all
Defined in:
lib/localjob/cli.rb

Instance Method Summary collapse

Instance Method Details

#destroy ⇒ Object 



28
29
30
31
32
 
# File 'lib/localjob/cli.rb', line 28

def destroy
  options[:queues].split(",").each do |queue|
    Localjob.new(queue).destroy
  end
end

#list ⇒ Object 



35
36
37
38
39
40
41
42
 
# File 'lib/localjob/cli.rb', line 35

def list
  unless File.exists?("/dev/mqueue")
    system "mkdir /dev/mqueue"
    system "mount -t mqueue none /dev/mqueue"
  end

  system "ls -l /dev/mqueue"
end

#size ⇒ Object 



19
20
21
22
23
24
 
# File 'lib/localjob/cli.rb', line 19

def size
  queues = options[:queues].split(",")
  queues.each do |queue|
    puts "Size of /#{queue}: #{Localjob.new(queue).size}/#{msg_max}"
  end
end

#work ⇒ Object 



10
11
12
13
14
15
 
# File 'lib/localjob/cli.rb', line 10

def work
  load_environment options[:require]

  queues = options[:queues].split(",")
  Localjob::Worker.new(queues, options.slice(:daemon, :pid_file)).work
end