rsudp.c_consumer (master consumer)

class rsudp.c_consumer.Consumer(queue, destinations)

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.

Parameters
run()

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 ↑