Package com.northconcepts.datapipeline.multiplex

Interface DeMux.IStrategy

All Known Implementing Classes:
DeMux.Strategy
Enclosing class:
DeMux
public static interface DeMux.IStrategy
Strategy for distributing the source records among the readers created by DeMux.createReader().

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    put(DeMux deMux, Record currentRecord)
    Queues a source record for one or more of the demultiplexer's readers; called on the feeder thread.
    Record
    take(com.northconcepts.datapipeline.multiplex.DeMuxReader reader)
    Returns the next record from the reader's queue, blocking until one is available; called on the reader's thread.

  • Method Details

    • put

      void put(DeMux deMux, Record currentRecord) throws Throwable
      Queues a source record for one or more of the demultiplexer's readers; called on the feeder thread.
      Throws:
      Throwable

    • take

      Record take(com.northconcepts.datapipeline.multiplex.DeMuxReader reader) throws Throwable
      Returns the next record from the reader's queue, blocking until one is available; called on the reader's thread.
      Throws:
      Throwable