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.

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.

---

• Index

• Search Page

Back to top ↑