Skip to main content

Examples

  • simplest: a very simple pipeline with just 2 queues connected with a DirectLink
  • simulation-fork: a somewhat complete example with DirectLink, ChoiceLink and Sink instances connecting 5 queues in a fork-like flow. Each process function adds some basic simulated processing with payload updates, random failures and random delays. It also uses deadletter
  • builder: variant of simulation-fork done with a pipeline builder
  • fromRecipe: variant of simulation-fork, almost identical to builder but using a factory.pipelineFromRecipe