rsudp.c_consumer (master consumer)

class rsudp.c_consumer.Consumer(queue, destinations, testing=False)

The main consumer process. This consumer reads queue messages from the rsudp.p_producer.Producer and distributes those messages to each sub-consumer in destinations.


Distributes queue objects to execute various other tasks: for example, it may be used to populate ObsPy streams for various things like plotting, alert triggers, and ground motion calculation.

Back to top ↑