From 43d6c5affc78755f8a45b242d8d39acc72bd3526 Mon Sep 17 00:00:00 2001
From: Steve Kemp <steve@steve.org.uk>
Date: Fri, 18 Dec 2015 15:44:24 +0200
Subject: Document queue

---
 queue/list/run.rb | 32 ++++++++++++++++++++++++++++++++
 1 file changed, 32 insertions(+)
 create mode 100755 queue/list/run.rb

(limited to 'queue/list/run.rb')

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
-- 
cgit v1.2.1