summaryrefslogtreecommitdiff
path: root/bin
diff options
context:
space:
mode:
Diffstat (limited to 'bin')
-rwxr-xr-xbin/custodian-enqueue5
-rwxr-xr-xbin/custodian-queue6
2 files changed, 3 insertions, 8 deletions
diff --git a/bin/custodian-enqueue b/bin/custodian-enqueue
index 1588638..7dd864b 100755
--- a/bin/custodian-enqueue
+++ b/bin/custodian-enqueue
@@ -60,10 +60,9 @@ if __FILE__ == $PROGRAM_NAME
end
#
- # Connected to the queue - be it redis or beanstalkd
+ # Connected to the queue.
#
- settings = Custodian::Settings.instance
- queue = Custodian::QueueType.create(settings.queue_type)
+ queue = Custodian::RedisQueueType.new()
unless queue
puts "Failed to connect to the #{settings.queue_type} queue"
exit 1
diff --git a/bin/custodian-queue b/bin/custodian-queue
index fcbf2b3..a78ae25 100755
--- a/bin/custodian-queue
+++ b/bin/custodian-queue
@@ -62,8 +62,7 @@ if __FILE__ == $PROGRAM_NAME
#
# Create the queue object.
#
- settings = Custodian::Settings.instance
- queue = Custodian::QueueType.create(settings.queue_type)
+ queue = Custodian::RedisQueueType.new()
#
# Alerting on a queue that is too-full?
@@ -129,9 +128,6 @@ __END__
# This tool is designed to inspect the global queue, and also allows that
# queue to be flushed of all pending-jobs.
#
-# The queue may be redis-based, or beanstalkd-based, as defined by the
-# global configuration-file.
-#
# AUTHOR
#
# Steve Kemp <steve@bytemark.co.uk>