Uses of Class
io.helidon.messaging.Messaging.Builder

Packages that use Messaging.Builder

Package	Description
io.helidon.messaging	Helidon Reactive Messaging.

Uses of Messaging.Builder in io.helidon.messaging

Methods in io.helidon.messaging that return Messaging.Builder

Modifier and Type	Method	Description
static Messaging.Builder	Messaging.builder()	Create builder for constructing new Messaging.
Messaging.Builder	Messaging.Builder.config(Config config)	Configuration needed for configuring connector and their routing.
Messaging.Builder	Messaging.Builder.connector(ConnectorFactory connector)	Add connector implementing IncomingConnectorFactory, OutgoingConnectorFactory or both.
<PAYLOAD> Messaging.Builder	Messaging.Builder.emitter(Emitter<PAYLOAD> emitter)	Register new emitter and all its channels.
<PAYLOAD> Messaging.Builder	Messaging.Builder.listener(Channel<PAYLOAD> channel, Consumer<? super PAYLOAD> consumer)	Register Consumer for listening every payload coming from upstream.
<PAYLOAD,RESULT> Messaging.Builder	Messaging.Builder.processor(Channel<PAYLOAD> in, Channel<RESULT> out, Function<? super PAYLOAD,? extends RESULT> messageFunction)	Register a mapping function between two channels.
<PAYLOAD,RESULT> Messaging.Builder	Messaging.Builder.processor(Channel<PAYLOAD> in, Channel<RESULT> out, ProcessorBuilder<? extends Message<? extends PAYLOAD>,? extends Message<? extends RESULT>> processorBuilder)	Register ProcessorBuilder for building Processor to be used is in Channel's subscriber and out Channel's publisher.
<PAYLOAD,RESULT> Messaging.Builder	Messaging.Builder.processor(Channel<PAYLOAD> in, Channel<RESULT> out, Processor<? extends Message<? extends PAYLOAD>,? extends Message<? extends RESULT>> processor)	Register Processor to be used is in Channel's subscriber and out Channel's publisher.
<PAYLOAD> Messaging.Builder	Messaging.Builder.publisher(Channel<PAYLOAD> channel, Flow.Publisher<? extends Message<? extends PAYLOAD>> publisher)	Register Flow.Publisher to be used for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.publisher(Channel<PAYLOAD> channel, Flow.Publisher<? extends PAYLOAD> publisher, Function<? super PAYLOAD,? extends Message<? extends PAYLOAD>> wrapper)	Register Flow.Publisher to be used for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.publisher(Channel<PAYLOAD> channel, PublisherBuilder<? extends Message<? extends PAYLOAD>> publisherBuilder)	Register PublisherBuilder to be used for construction of the publisher for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.publisher(Channel<PAYLOAD> channel, Publisher<? extends Message<? extends PAYLOAD>> publisher)	Register Publisher to be used for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.publisher(Channel<PAYLOAD> channel, Publisher<? extends PAYLOAD> publisher, Function<? super PAYLOAD,? extends Message<? extends PAYLOAD>> wrapper)	Register Publisher to be used for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.subscriber(Channel<PAYLOAD> channel, Flow.Subscriber<? extends Message<? extends PAYLOAD>> subscriber)	Register Flow.Subscriber to be used for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.subscriber(Channel<PAYLOAD> channel, Consumer<Multi<? extends Message<? extends PAYLOAD>>> consumer)	Use provided Multi to subscribe to supplied Channel.
<PAYLOAD,RESULT> Messaging.Builder	Messaging.Builder.subscriber(Channel<PAYLOAD> channel, SubscriberBuilder<? extends Message<? extends PAYLOAD>,RESULT> subscriberBuilder)	Register SubscriberBuilder to be used for creating Subscriber for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.subscriber(Channel<PAYLOAD> channel, Subscriber<? extends Message<? extends PAYLOAD>> subscriber)	Register Subscriber to be used for supplied Channel.