io.smallrye.reactive.messaging.impl

Class ConfiguredChannelFactory

java.lang.Object

io.smallrye.reactive.messaging.impl.ConfiguredChannelFactory

All Implemented Interfaces:

ChannelRegistar

Direct Known Subclasses:

LegacyConfiguredChannelFactory

@ApplicationScoped
public class ConfiguredChannelFactory
extends Object
implements ChannelRegistar

Look for stream factories and get instances.

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ConfiguredChannelFactory()
	ConfiguredChannelFactory(javax.enterprise.inject.Instance<IncomingConnectorFactory> incomingConnectorFactories, javax.enterprise.inject.Instance<OutgoingConnectorFactory> outgoingConnectorFactories, javax.enterprise.inject.Instance<org.eclipse.microprofile.config.Config> config, javax.enterprise.inject.Instance<ChannelRegistry> registry, javax.enterprise.inject.spi.BeanManager beanManager)

Method Summary

Modifier and Type	Method and 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(@Any
                                        javax.enterprise.inject.Instance<IncomingConnectorFactory> incomingConnectorFactories,
                                        @Any
                                        javax.enterprise.inject.Instance<OutgoingConnectorFactory> outgoingConnectorFactories,
                                        javax.enterprise.inject.Instance<org.eclipse.microprofile.config.Config> config,
                                        @Any
                                        javax.enterprise.inject.Instance<ChannelRegistry> registry,
                                        javax.enterprise.inject.spi.BeanManager beanManager)

Method Detail

initialize

public void initialize()

Specified by:

initialize in interface ChannelRegistar