Package io.smallrye.reactive.messaging.impl

Class ConfiguredChannelFactory

java.lang.Object

io.smallrye.reactive.messaging.impl.ConfiguredChannelFactory

All Implemented Interfaces:

ChannelRegistar

@ApplicationScoped
public class ConfiguredChannelFactory
extends Object
implements ChannelRegistar

Look for stream factories and get instances.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.eclipse.microprofile.config.Config	config
protected ChannelRegistry	registry

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConfiguredChannelFactory()
	ConfiguredChannelFactory(ConnectorFactories factories, javax.enterprise.inject.Instance<org.eclipse.microprofile.config.Config> config, javax.enterprise.inject.Instance<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 Detail

config

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

registry

protected final ChannelRegistry registry

Constructor Detail

ConfiguredChannelFactory

protected ConfiguredChannelFactory()

ConfiguredChannelFactory

@Inject
public ConfiguredChannelFactory(ConnectorFactories factories,
                                javax.enterprise.inject.Instance<org.eclipse.microprofile.config.Config> config,
                                @Any
                                javax.enterprise.inject.Instance<ChannelRegistry> registry)

Method Detail

initialize

public void initialize()

Specified by:

initialize in interface ChannelRegistar