Class MessagingConfig.Builder

java.lang.Object

io.helidon.messaging.MessagingConfig.BuilderBase<MessagingConfig.Builder, MessagingConfig>

io.helidon.messaging.MessagingConfig.Builder

All Implemented Interfaces:

Prototype.Builder<MessagingConfig.Builder, MessagingConfig>, Builder<MessagingConfig.Builder, MessagingGraph>, ConfigBuilderSupport.ConfiguredBuilder<MessagingConfig.Builder, MessagingConfig>, Supplier<MessagingGraph>

Enclosing interface:

MessagingConfig

public static class MessagingConfig.Builder
extends MessagingConfig.BuilderBase<MessagingConfig.Builder, MessagingConfig>
implements Builder<MessagingConfig.Builder, MessagingGraph>

Fluent API builder for MessagingGraph.

Method Summary

Modifier and Type	Method	Description
MessagingGraph	build()	Create an instance from this builder.
MessagingConfig	buildPrototype()	Create an instance of the prototype.

Methods inherited from class MessagingConfig.BuilderBase

addConnector, addConnector, addConsumerRegistration, addConsumerRegistrations, addEmitterRegistration, addEmitterRegistrations, addIncoming, addOutgoing, admissionTimeout, admissionTimeout, batchSink, buildPrototype, channel, clearAdmissionTimeout, clearConnector, clearConsumerRegistrations, clearEmitterRegistrations, config, config, connector, connector, connectorDiscoverServices, connectorDiscoverServices, consumerRegistrations, consumerRegistrations, emitterRegistrations, emitterRegistrations, from, from, incoming, incoming, incomingChannel, maxInFlightMessages, maxInFlightMessages, maxPendingAdmissions, maxPendingAdmissions, maxPendingMessages, maxPendingMessages, messageProcessor, messageSink, messageSource, outgoing, outgoing, outgoingChannel, payloadProcessor, payloadSink, payloadSource, preBuildPrototype, queueCapacity, queueCapacity, route, serviceRegistry, serviceRegistry, shutdownTimeout, shutdownTimeout, toString, validatePrototype

Modifier and Type	Method	Description
MessagingConfig.Builder	addConnector(MessagingConnector connector)	Configured messaging connectors.
MessagingConfig.Builder	addConnector(List<? extends MessagingConnector> connector)	Configured messaging connectors.
MessagingConfig.Builder	addConsumerRegistration(ConsumerRegistration consumerRegistration)	Consumer and processor registrations contributing channel outputs.
MessagingConfig.Builder	addConsumerRegistrations(List<? extends ConsumerRegistration> consumerRegistrations)	Consumer and processor registrations contributing channel outputs.
MessagingConfig.Builder	addEmitterRegistration(EmitterRegistration emitterRegistration)	Emitter registrations contributing typed producer metadata.
MessagingConfig.Builder	addEmitterRegistrations(List<? extends EmitterRegistration> emitterRegistrations)	Emitter registrations contributing typed producer metadata.
MessagingConfig.Builder	addIncoming(Map<String, ? extends MessagingIncomingConfig> incoming)	Incoming channel configurations, keyed by channel name, whose execution settings take precedence over outgoing configurations of the same logical channel.
MessagingConfig.Builder	addOutgoing(Map<String, ? extends MessagingOutgoingConfig> outgoing)	Outgoing channel configurations, keyed by channel name; their execution settings apply only when the logical channel has no incoming configuration.
Optional<Duration>	admissionTimeout()	Positive maximum capacity-wait time, representable in nanoseconds.
MessagingConfig.Builder	admissionTimeout(Duration admissionTimeout)	Positive maximum capacity-wait time, representable in nanoseconds.
<T> MessagingConfig.Builder	batchSink(MessagingChannel<T> source, Consumer<MessageBatch<T>> sink)	Add a message batch sink.
protected final MessagingConfig	buildPrototype(MessagingConfig.BuilderBase<?,?> builder)	Create a new prototype instance from a builder.
MessagingConfig.Builder	channel(MessagingChannel<?> channel)	Register a typed channel handle.
MessagingConfig.Builder	clearAdmissionTimeout()	Clear existing value of admissionTimeout.
MessagingConfig.Builder	clearConnector()	Clear all connector.
MessagingConfig.Builder	clearConsumerRegistrations()	Clear all consumerRegistrations.
MessagingConfig.Builder	clearEmitterRegistrations()	Clear all emitterRegistrations.
protected Optional<Config>	config()	Configuration used to configure this instance.
MessagingConfig.Builder	config(Config config)	Update builder from configuration (node of this type).
List<MessagingConnector>	connector()	Configured messaging connectors.
MessagingConfig.Builder	connector(List<? extends MessagingConnector> connector)	Configured messaging connectors.
boolean	connectorDiscoverServices()	Service discovery flag for MessagingConfig.BuilderBase.connector().
MessagingConfig.Builder	connectorDiscoverServices(boolean connectorDiscoverServices)	Service discovery flag for MessagingConfig.BuilderBase.connector().
List<ConsumerRegistration>	consumerRegistrations()	Consumer and processor registrations contributing channel outputs.
MessagingConfig.Builder	consumerRegistrations(List<? extends ConsumerRegistration> consumerRegistrations)	Consumer and processor registrations contributing channel outputs.
List<EmitterRegistration>	emitterRegistrations()	Emitter registrations contributing typed producer metadata.
MessagingConfig.Builder	emitterRegistrations(List<? extends EmitterRegistration> emitterRegistrations)	Emitter registrations contributing typed producer metadata.
MessagingConfig.Builder	from(MessagingConfig prototype)	Update this builder from an existing prototype instance.
MessagingConfig.Builder	from(MessagingConfig.BuilderBase<?,?> builder)	Update this builder from an existing prototype builder instance.
Map<String, MessagingIncomingConfig>	incoming()	Incoming channel configurations, keyed by channel name, whose execution settings take precedence over outgoing configurations of the same logical channel.
MessagingConfig.Builder	incoming(Map<String, ? extends MessagingIncomingConfig> incoming)	Incoming channel configurations, keyed by channel name, whose execution settings take precedence over outgoing configurations of the same logical channel.
<T> MessagingConfig.Builder	incomingChannel(MessagingChannel<T> target, IncomingChannel connection)	Add an incoming channel connection as a source.
int	maxInFlightMessages()	Positive maximum number of admitted messages, including queued and executing deliveries.
MessagingConfig.Builder	maxInFlightMessages(int maxInFlightMessages)	Positive maximum number of admitted messages, including queued and executing deliveries.
int	maxPendingAdmissions()	Positive maximum number of waiting callers and open connector reservations.
MessagingConfig.Builder	maxPendingAdmissions(int maxPendingAdmissions)	Positive maximum number of waiting callers and open connector reservations.
int	maxPendingMessages()	Positive maximum number of messages retained by waiting callers and open connector reservations.
MessagingConfig.Builder	maxPendingMessages(int maxPendingMessages)	Positive maximum number of messages retained by waiting callers and open connector reservations.
<I,O> MessagingConfig.Builder	messageProcessor(MessagingChannel<I> source, MessagingChannel<O> target, Function<? super Message<I>, ? extends Message<? extends O>> processor)	Add a message processor.
<T> MessagingConfig.Builder	messageSink(MessagingChannel<T> source, Consumer<? super Message<T>> sink)	Add a message sink.
<T> MessagingConfig.Builder	messageSource(MessagingChannel<T> channel, Stream<? extends Message<? extends T>> source)	Add a message stream source.
Map<String, MessagingOutgoingConfig>	outgoing()	Outgoing channel configurations, keyed by channel name; their execution settings apply only when the logical channel has no incoming configuration.
MessagingConfig.Builder	outgoing(Map<String, ? extends MessagingOutgoingConfig> outgoing)	Outgoing channel configurations, keyed by channel name; their execution settings apply only when the logical channel has no incoming configuration.
<T> MessagingConfig.Builder	outgoingChannel(MessagingChannel<T> source, OutgoingChannel connection)	Add an outgoing channel connection as a required channel output.
<I,O> MessagingConfig.Builder	payloadProcessor(MessagingChannel<I> source, MessagingChannel<O> target, Function<? super I, ? extends O> processor)	Add a payload processor.
<T> MessagingConfig.Builder	payloadSink(MessagingChannel<T> source, Consumer<? super T> sink)	Add a payload sink.
<T> MessagingConfig.Builder	payloadSource(MessagingChannel<T> channel, Stream<? extends T> source)	Add a payload stream source.
protected void	preBuildPrototype()	Handles providers and decorators.
int	queueCapacity()	Maximum number of admitted deliveries waiting for execution.
MessagingConfig.Builder	queueCapacity(int queueCapacity)	Maximum number of admitted deliveries waiting for execution.
<T> MessagingConfig.Builder	route(MessagingChannel<T> source, MessagingChannel<T> target)	Route each delivery batch unchanged from one channel to another channel of the same type.
Optional<ServiceRegistry>	serviceRegistry()	Service registry used to discover providers and services.
MessagingConfig.Builder	serviceRegistry(ServiceRegistry serviceRegistry)	Service registry used to discover providers and services.
Duration	shutdownTimeout()	Positive global maximum shutdown and failed-startup rollback time, representable in nanoseconds.
MessagingConfig.Builder	shutdownTimeout(Duration shutdownTimeout)	Positive global maximum shutdown and failed-startup rollback time, representable in nanoseconds.
String	toString()
protected void	validatePrototype()	Validates required properties.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface Builder

get, identity, update

Modifier and Type	Method	Description
default MessagingGraph	get()
default MessagingConfig.Builder	identity()	Instance of this builder as the correct type.
default MessagingConfig.Builder	update(Consumer<MessagingConfig.Builder> consumer)	Update the builder in a fluent API way.

Methods inherited from interface Prototype.Builder

self

Modifier and Type	Method	Description
default MessagingConfig.Builder	self()	Instance of this builder as the correct type.

Method Details

buildPrototype

public MessagingConfig buildPrototype()

Create an instance of the prototype. Calling this method may update this builder from providers and decorators, so repeated calls may have side effects.

Specified by:

buildPrototype in interface Prototype.Builder<MessagingConfig.Builder, MessagingConfig>

Returns:

an instance of the setup object created from this builder

build

public MessagingGraph build()

Create an instance from this builder. Calling this method may update this builder from providers and decorators, so repeated calls may have side effects.

Specified by:

build in interface Builder<MessagingConfig.Builder, MessagingGraph>

Returns:

instance of the built type