diff options
author | Steve Kemp <steve@steve.org.uk> | 2016-01-18 14:16:07 +0200 |
---|---|---|
committer | Steve Kemp <steve@steve.org.uk> | 2016-01-18 14:16:07 +0200 |
commit | c6f2c6f924e6b263be5a3ba4a4eb7049f27544d3 (patch) | |
tree | e023f6bbef8a2ecf8829a0d0ab5214b902266bc7 /queue/set/run.rb | |
parent | fbd4e3bf99afbc80012d6dc029be19e1bd8e6890 (diff) |
Removed queue-examples.
These are no longer required now we're sure we understand the process
of adding jobs to the queue without duplication.
Diffstat (limited to 'queue/set/run.rb')
-rwxr-xr-x | queue/set/run.rb | 32 |
1 files changed, 0 insertions, 32 deletions
diff --git a/queue/set/run.rb b/queue/set/run.rb deleted file mode 100755 index f0b7476..0000000 --- a/queue/set/run.rb +++ /dev/null @@ -1,32 +0,0 @@ -#!/usr/bin/ruby - -require "redis" -require 'pp' -@redis = Redis.new(:host => "127.0.0.1") - - - -def fetch(timeout = 1) - job = nil - - loop do - job = @redis.spop('set') - - if !job.nil? - return job - else - sleep(timeout) - end - - end -end - - - -while( x = fetch() ) - puts "Got job : #{x}" - if ( x =~ /ping/i ) - puts "PING TEST - sleeping" - sleep 5 - end -end |