Package io.smallrye.reactive.messaging.providers.impl

Class ConfiguredChannelFactory

java.lang.Object

io.smallrye.reactive.messaging.providers.impl.ConfiguredChannelFactory

All Implemented Interfaces:

io.smallrye.reactive.messaging.ChannelRegistar

@ApplicationScoped
public class ConfiguredChannelFactory
extends Object
implements io.smallrye.reactive.messaging.ChannelRegistar

Look for stream factories and get instances.

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.eclipse.microprofile.config.Config	config
protected final io.smallrye.reactive.messaging.ChannelRegistry	registry
static final String	SMALLRYE_PREFIX

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConfiguredChannelFactory()
	ConfiguredChannelFactory(ConnectorFactories factories, jakarta.enterprise.inject.Instance<org.eclipse.microprofile.config.Config> config, jakarta.enterprise.inject.Instance<io.smallrye.reactive.messaging.ChannelRegistry> registry)

Method Summary

Modifier and Type	Method	Description
void	initialize()

Methods inherited from class java.lang.Object

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

Field Details

SMALLRYE_PREFIX

public static final String SMALLRYE_PREFIX

See Also:

• Constant Field Values

config

protected final org.eclipse.microprofile.config.Config config

registry

protected final io.smallrye.reactive.messaging.ChannelRegistry registry

Constructor Details

ConfiguredChannelFactory

protected ConfiguredChannelFactory()

ConfiguredChannelFactory

@Inject
public ConfiguredChannelFactory(ConnectorFactories factories,
 jakarta.enterprise.inject.Instance<org.eclipse.microprofile.config.Config> config,
 @Any
 jakarta.enterprise.inject.Instance<io.smallrye.reactive.messaging.ChannelRegistry> registry)

Method Details

initialize

public void initialize()

Specified by:

initialize in interface io.smallrye.reactive.messaging.ChannelRegistar