DSL

The Pipelite DSL is a fluent, type-safe Java API that allows integration pipelines to be defined declaratively. The entry point is always Pipelite.defineFlow(name), which returns a builder with steps constrained by the interface hierarchy.

Operation hierarchy

FlowOperations
  └─ .fromSource(url)  ──► SourceOperations
                               extends ProcessOperations
                                 ├─ .process(...)
                                 ├─ .transformPayload(...)
                                 ├─ .filter(...)
                                 ├─ .wireTap(...)
                                 ├─ .split(...)
                                 ├─ .toRoute(...)        ──► BuildOperations
                                 └─ .toSink(url)         ──► SinkOperations
                                                               extends BuildOperations
                                                                 ├─ .withRetryChannel()
                                                                 ├─ .withErrorChannel(...)
                                                                 └─ .build()

The interface hierarchy ensures that the Java compiler enforces the correct sequence: source → processors → sink → error handling → build.

Page Content

Flow Definition

All builder operations: fromSource, process, transformPayload, filter, wireTap, toSink, withRetryChannel, withErrorChannel, build.

Routing

Content-based routing, recipient list, and routing slip.

Split / Aggregate

Splitting a collection payload into independent messages and aggregating the results.

Expressions

Expression syntax used by filter and routers.