Uses of Interface
io.helidon.messaging.MessagingChannel

Packages that use MessagingChannel

Package	Description
io.helidon.messaging	Helidon Messaging API and runtime.

Uses of MessagingChannel in io.helidon.messaging

Classes in io.helidon.messaging with type parameters of type MessagingChannel

Modifier and Type	Class	Description
static class	MessagingChannel.BuilderBase<T, BUILDER extends MessagingChannel.BuilderBase<T, BUILDER, PROTOTYPE>, PROTOTYPE extends MessagingChannel<T>>	Fluent API builder base for MessagingChannel.

Classes in io.helidon.messaging that implement MessagingChannel

Modifier and Type	Class	Description
protected static class	MessagingChannel.BuilderBase.MessagingChannelImpl<T>	Generated implementation of the prototype, can be extended by descendant prototype implementations.

Subclasses with type arguments of type MessagingChannel in io.helidon.messaging

Modifier and Type	Class	Description
static class	MessagingChannel.Builder<T>	Fluent API builder for MessagingChannel.

Classes in io.helidon.messaging that implement interfaces with type arguments of type MessagingChannel

Modifier and Type	Class	Description
static class	MessagingChannel.Builder<T>	Fluent API builder for MessagingChannel.

Methods in io.helidon.messaging that return MessagingChannel

Modifier and Type	Method	Description
MessagingChannel<T>	MessagingChannel.Builder.build()	Create an instance from this builder.
MessagingChannel<T>	MessagingChannel.Builder.buildPrototype()	Create an instance of the prototype.
static <T> MessagingChannel<T>	MessagingChannel.create(String name, GenericType<T> payloadType)	Create a channel handle preserving the complete payload type.
static <T> MessagingChannel<T>	MessagingChannel.create(String name, Class<T> payloadType)	Create a typed channel handle.

Methods in io.helidon.messaging that return types with arguments of type MessagingChannel

Modifier and Type	Method	Description
List<MessagingChannel<?>>	MessagingConfig.channelHandles()	Programmatic channel handles.
Map<MessagingChannel<?>, IncomingChannel>	MessagingConfig.incomingConnections()	Programmatic incoming channel connections.

Methods in io.helidon.messaging with parameters of type MessagingChannel

Modifier and Type	Method	Description
<T> BUILDER	MessagingConfig.BuilderBase.batchSink(MessagingChannel<T> source, Consumer<MessageBatch<T>> sink)	Add a message batch sink.
static <T> MessagingChannel.Builder<T>	MessagingChannel.builder(MessagingChannel<T> instance)	Create a new fluent API builder from an existing instance.
BUILDER	MessagingConfig.BuilderBase.channel(MessagingChannel<?> channel)	Register a typed channel handle.
<T> Emitter<T>	MessagingGraph.emitter(MessagingChannel<T> channel)	Obtain an imperative emitter for a channel owned by this graph.
BUILDER	MessagingChannel.BuilderBase.from(MessagingChannel<T> prototype)	Update this builder from an existing prototype instance.
<T> BUILDER	MessagingConfig.BuilderBase.incomingChannel(MessagingChannel<T> target, IncomingChannel connection)	Add an incoming channel connection as a source.
<I,O> BUILDER	MessagingConfig.BuilderBase.messageProcessor(MessagingChannel<I> source, MessagingChannel<O> target, Function<? super Message<I>, ? extends Message<? extends O>> processor)	Add a message processor.
<T> BUILDER	MessagingConfig.BuilderBase.messageSink(MessagingChannel<T> source, Consumer<? super Message<T>> sink)	Add a message sink.
<T> BUILDER	MessagingConfig.BuilderBase.messageSource(MessagingChannel<T> channel, Stream<? extends Message<? extends T>> source)	Add a message stream source.
<T> BUILDER	MessagingConfig.BuilderBase.outgoingChannel(MessagingChannel<T> source, OutgoingChannel connection)	Add an outgoing channel connection as a required channel output.
<I,O> BUILDER	MessagingConfig.BuilderBase.payloadProcessor(MessagingChannel<I> source, MessagingChannel<O> target, Function<? super I, ? extends O> processor)	Add a payload processor.
<T> BUILDER	MessagingConfig.BuilderBase.payloadSink(MessagingChannel<T> source, Consumer<? super T> sink)	Add a payload sink.
<T> BUILDER	MessagingConfig.BuilderBase.payloadSource(MessagingChannel<T> channel, Stream<? extends T> source)	Add a payload stream source.
<T> BUILDER	MessagingConfig.BuilderBase.route(MessagingChannel<T> source, MessagingChannel<T> target)	Route each delivery batch unchanged from one channel to another channel of the same type.