summaryrefslogtreecommitdiff
path: root/python/setadm.py
diff options
context:
space:
mode:
authorMarko Kreen2009-02-13 12:16:59 +0000
committerMarko Kreen2009-02-13 13:20:31 +0000
commit411f237ebfdce9532bbf01f51d46cdb91f7fe283 (patch)
tree851a378f1234629cf2f15d903ecea4ae88df126f /python/setadm.py
parentc8198c637b777296ec49b845395487242d730394 (diff)
python/pgq update
- remove the obsolete setconsumer stuff - New CascadedConsumer / CascadedWorker classes, that are based on regular pgq.Consumer - move RemoteConsumer / SerialConsumer out of pgq/consumer.py pgq.Consumer: - rename conf params and instance variables: pgq_queue_name -> queue_name pgq_consumer_id -> consumer_name - disable automatic registration on the queue, now script needs to be called with switches --register / --unregister - drop code to read from multiple-queues at once pgq.ticker: - drop event seq tracking code, this is now done in db
Diffstat (limited to 'python/setadm.py')
-rwxr-xr-xpython/setadm.py7
1 files changed, 5 insertions, 2 deletions
diff --git a/python/setadm.py b/python/setadm.py
index 61cfdc77..2c93d4ef 100755
--- a/python/setadm.py
+++ b/python/setadm.py
@@ -1,8 +1,11 @@
#! /usr/bin/env python
-import sys, pgq.setadmin
+"""SetAdmin launcher.
+"""
+
+import sys, pgq.cascade.admin
if __name__ == '__main__':
- script = pgq.setadmin.SetAdmin('set_admin', sys.argv[1:])
+ script = pgq.cascade.admin.CascadeAdmin('cascade_admin', 'node_db', sys.argv[1:], worker_setup = False)
script.start()