·¬ÇÑÉçÇø

Dari includes the following classes for implementing queue processing background tasks that run asynchronously.

•  represents an asynchronous queue.
•  creates data and puts it (produces) into an output queue. A subclass must implement the produce method.
•  reads from an input queue and processes (consumes) the data. For example, a consumer can transform the data and save it to a database or put it in another queue. A subclass must implement the consume method.
•  does both: it consumes all items from an input queue, processes them, and produces new items into an output queue. A subclass must implement the process method.

Dari provides queue processing database support that is implemented from the above collection of classes. You can also implement these classes to create queue pipelines.