python/pgq update
authorMarko Kreen <markokr@gmail.com>
Fri, 13 Feb 2009 12:16:59 +0000 (14:16 +0200)
committerMarko Kreen <markokr@gmail.com>
Fri, 13 Feb 2009 13:20:31 +0000 (15:20 +0200)
commit411f237ebfdce9532bbf01f51d46cdb91f7fe283
tree851a378f1234629cf2f15d903ecea4ae88df126f
parentc8198c637b777296ec49b845395487242d730394
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
18 files changed:
python/conf/pgqadm.ini
python/pgq/__init__.py
python/pgq/cascade/__init__.py [new file with mode: 0644]
python/pgq/cascade/admin.py [new file with mode: 0644]
python/pgq/cascade/consumer.py [new file with mode: 0644]
python/pgq/cascade/nodeinfo.py [moved from python/pgq/setinfo.py with 54% similarity]
python/pgq/cascade/worker.py [new file with mode: 0644]
python/pgq/consumer.py
python/pgq/event.py
python/pgq/maint.py
python/pgq/rawconsumer.py [deleted file]
python/pgq/remoteconsumer.py [new file with mode: 0644]
python/pgq/setadmin.py [deleted file]
python/pgq/setconsumer.py [deleted file]
python/pgq/status.py
python/pgq/ticker.py
python/pgqadm.py
python/setadm.py