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).
Link	`link://`	`default-channel-adapters`	Direct link between two internal 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).

Link

link://

default-channel-adapters

Direct link between two internal flows.

Automatic discovery

Adapters are registered via the file:

META-INF/pipelite/adapters

Each line contains the fully qualified name of a class implementing ChannelAdapter. The FactoryComponentClasspathScanner loads the classes at context startup.

Creating a custom adapter

See Custom Adapter for the SPI implementation guide.