Package io.smallrye.reactive.messaging.impl

Class LegacyConfiguredChannelFactory

java.lang.Object

io.smallrye.reactive.messaging.impl.ConfiguredChannelFactory

io.smallrye.reactive.messaging.impl.LegacyConfiguredChannelFactory

All Implemented Interfaces:

ChannelRegistar

@ApplicationScoped
public class LegacyConfiguredChannelFactory
extends ConfiguredChannelFactory

Look for stream factories and get instances. This implementation use the "smallrye.messaging.source" and "smallrye.messaging.sink" prefixes.

Field Summary

Fields inherited from class io.smallrye.reactive.messaging.impl.ConfiguredChannelFactory

config, registry

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	LegacyConfiguredChannelFactory()
	LegacyConfiguredChannelFactory(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	Description
void	initialize()

Methods inherited from class java.lang.Object

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

Constructor Detail

LegacyConfiguredChannelFactory

protected LegacyConfiguredChannelFactory()

LegacyConfiguredChannelFactory

@Inject
public LegacyConfiguredChannelFactory(@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

Overrides:

initialize in class ConfiguredChannelFactory