summaryrefslogtreecommitdiff
path: root/bin
diff options
context:
space:
mode:
Diffstat (limited to 'bin')
-rwxr-xr-xbin/custodian-queue13
1 files changed, 1 insertions, 12 deletions
diff --git a/bin/custodian-queue b/bin/custodian-queue
index 01fb381..978cbda 100755
--- a/bin/custodian-queue
+++ b/bin/custodian-queue
@@ -159,18 +159,7 @@ if __FILE__ == $0 then
# Are we flushing the queue?
#
if ( $FLUSH )
- count = 0
- run = true
- while( run )
- begin
- job = queue.fetch(1)
- exit(0) if ( job.nil? )
- count += 1
- rescue Beanstalk::TimedOut => ex
- puts "Flushed #{count} pending jobs."
- exit( 0 )
- end
- end
+ queue.flush!
end