Package io.smallrye.reactive.messaging.providers.wiring

Class Wiring

java.lang.Object

io.smallrye.reactive.messaging.providers.wiring.Wiring

@ApplicationScoped
public class Wiring
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Wiring.Component
static interface	Wiring.ConsumingComponent
static interface	Wiring.PublishingComponent

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_BUFFER_SIZE

Constructor Summary

Constructors

Constructor	Description
Wiring()

Method Summary

Modifier and Type	Method	Description
Graph	getGraph()
void	prepare(boolean strictMode, io.smallrye.reactive.messaging.ChannelRegistry registry, List<io.smallrye.reactive.messaging.EmitterConfiguration> emitters, List<ChannelConfiguration> channels, List<io.smallrye.reactive.messaging.MediatorConfiguration> mediators)
Graph	resolve()
void	terminateAllComponents()
static void	wireOutgoingConnectorToUpstream(io.smallrye.mutiny.Multi<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> multi, Flow.Subscriber outgoingConnector, jakarta.enterprise.inject.Instance<io.smallrye.reactive.messaging.SubscriberDecorator> subscriberDecorators, String channelName)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_BUFFER_SIZE

public static final int DEFAULT_BUFFER_SIZE

See Also:

• Constant Field Values

Constructor Details

Wiring

public Wiring()

Method Details

terminateAllComponents

@PreDestroy
public void terminateAllComponents()

prepare

public void prepare(boolean strictMode,
 io.smallrye.reactive.messaging.ChannelRegistry registry,
 List<io.smallrye.reactive.messaging.EmitterConfiguration> emitters,
 List<ChannelConfiguration> channels,
 List<io.smallrye.reactive.messaging.MediatorConfiguration> mediators)

resolve

public Graph resolve()

getGraph

public Graph getGraph()

wireOutgoingConnectorToUpstream

public static void wireOutgoingConnectorToUpstream(io.smallrye.mutiny.Multi<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> multi,
 Flow.Subscriber outgoingConnector,
 jakarta.enterprise.inject.Instance<io.smallrye.reactive.messaging.SubscriberDecorator> subscriberDecorators,
 String channelName)