1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
|
require 'term/ansicolor'
class String; include Term::ANSIColor; end
def step(msg); "\n[STEP] #{msg}...".yellow; end
$:.unshift("../lib")
require 'beaneater'
# Establish a pool of beanstalks
puts step("Connecting to Beanstalk")
bc = Beaneater.new('localhost')
puts bc
# Print out key stats
puts step("Print Stats")
p bc.stats.keys
p [bc.stats.total_connections, bc.stats[:total_connections], bc.stats['total_connections']]
# find tube
puts step("Find tube")
tube = bc.tubes.find('tube2')
puts tube
# Put job onto tube
puts step("Put job")
response = tube.put "foo bar", :pri => 1000, :ttr => 10, :delay => 0
puts response
# peek tube
puts step("Peek tube")
p tube.peek :ready
# watch tube
bc.tubes.watch!('tube2')
# Check tube stats
puts step("Get tube stats")
p tube.stats.keys
p tube.stats.name
p tube.stats.current_jobs_ready
# Reserve job from tube
puts step("Reserve job")
p job = bc.tubes.reserve
jid = job.id
# pause tube
puts step("Pause tube")
p tube.pause(1)
# Register jobs
puts step("Register jobs for tubes")
bc.jobs.register('tube_test', :retry_on => [Timeout::Error]) do |job|
p 'tube_test'
p job
raise Beaneater::AbortProcessingError
end
bc.jobs.register('tube_test2', :retry_on => [Timeout::Error]) do |job|
p 'tube_test2'
p job
raise Beaneater::AbortProcessingError
end
p bc.jobs.processors
response = bc.tubes.find('tube_test').put "foo register", :pri => 1000, :ttr => 10, :delay => 0
response = bc.tubes.find('tube_test2').put "foo baz", :pri => 1000, :ttr => 10, :delay => 0
# Process jobs
puts step("Process jobs")
2.times { bc.jobs.process! }
# Get job from id (peek job)
puts step("Get job from id")
p bc.jobs.find(jid)
p bc.jobs.peek(jid)
# Check job stats
puts step("Get job stats")
p job.stats.keys
p job.stats.tube
p job.stats.state
# bury job
puts step("Bury job")
p job.bury
# delete job
puts step("Delete job")
p job.delete
# list tubes
puts step("List tubes")
p bc.tubes.watched
p bc.tubes.used
p bc.tubes.all
|
