Package pgq :: Module consumer :: Class Consumer

Class Consumer

                 object --+    
                          |    
skytools.scripting.DBScript --+
                              |
                             Consumer

Known Subclasses:: RemoteConsumer, SerialConsumer

Consumer base class.

Instance Methods

__init__(self, service_name, db_name, args)
Initialize new consumer.

source code

attach(self)
Attach consumer to interesting queues.

source code

detach(self)
Detach consumer from all queues.

source code

process_event(self, db, event)
Process one event.

source code

process_batch(self, db, batch_id, event_list)
Process all events in batch.

source code

work(self)
Do the work loop, once (internal).

source code

register_consumer(self, queue_name)

source code

unregister_consumer(self, queue_name)

source code

get_batch_info(self, batch_id)
Get info about batch.

source code

stat_start(self)

source code

stat_end(self, count)

source code

Inherited from skytools.scripting.DBScript: close_database, get_database, hook_sighup, hook_sigint, init_optparse, reload, reset, run, run_once, send_signal, send_stats, set_single_loop, start, startup, stat_add, stat_increase, stat_put, stop

Inherited from object: __delattr__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __str__