This version is still in development and is not considered stable yet.

Channel Adapters

Channel Adapters are the connectors that link a Pipelite pipeline to external systems. Each adapter implements the SPI interface ChannelAdapter and is automatically discovered at runtime via classpath scan.

Available adapters

Adapter URL scheme Module Description

Adapter	URL scheme	Module	Description
HTTP	`http://`	`http-channel-adapter`	Inbound HTTP server (Undertow) and outbound HTTP client.
Kafka	`kafka://`	`kafka-channel-adapter`	Apache Kafka consumer and producer.
File	`file://`	`file-channel-adapter`	Filesystem tail-polling source and file-writing sink.
Time	`time://`	`default-channel-adapters`	Periodic tick generator (cron-like).
SLF4J	`slf4j://`	`default-channel-adapters`	Payload logging via SLF4J (sink only).
Queue	`queue://`	`default-channel-adapters`	The queue in front of an internal flow, to chain flows.

HTTP

http://

http-channel-adapter

Inbound HTTP server (Undertow) and outbound HTTP client.

Kafka

kafka://

kafka-channel-adapter

Apache Kafka consumer and producer.

File

file://

file-channel-adapter

Filesystem tail-polling source and file-writing sink.

Time

time://

default-channel-adapters

Periodic tick generator (cron-like).

SLF4J

slf4j://

default-channel-adapters

Payload logging via SLF4J (sink only).

Queue

queue://

default-channel-adapters

The queue in front of an internal flow, to chain flows.

Automatic discovery

Adapters are registered via the file:

META-INF/pipelite.factories

Each line maps a protocol to the fully qualified name of a class implementing ChannelAdapter:

queue=io.pipelite.components.queue.QueueChannelAdapter
time=io.pipelite.components.time.TimeChannelAdapter

Every such file on the classpath is scanned at context startup.

Creating a custom adapter

See Custom Adapter for the SPI implementation guide.