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 indestinations
.Parameters: - queue (queue.Queue) – queue of data and messages sent by
rsudp.p_producer.Producer
- destinations (list) – list of
queue.Queue
objects to pass data to
-
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.
- queue (queue.Queue) – queue of data and messages sent by