summaryrefslogtreecommitdiff
path: root/queue/list/run.rb
diff options
context:
space:
mode:
Diffstat (limited to 'queue/list/run.rb')
-rwxr-xr-xqueue/list/run.rb32
1 files changed, 32 insertions, 0 deletions
diff --git a/queue/list/run.rb b/queue/list/run.rb
new file mode 100755
index 0000000..08623b0
--- /dev/null
+++ b/queue/list/run.rb
@@ -0,0 +1,32 @@
+#!/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.lpop('list')
+
+ 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