diff options
author | Marko Kreen | 2009-02-13 12:16:59 +0000 |
---|---|---|
committer | Marko Kreen | 2009-02-13 13:20:31 +0000 |
commit | 411f237ebfdce9532bbf01f51d46cdb91f7fe283 (patch) | |
tree | 851a378f1234629cf2f15d903ecea4ae88df126f /python/setadm.py | |
parent | c8198c637b777296ec49b845395487242d730394 (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-x | python/setadm.py | 7 |
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() |