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

Class ConnectorConfig

java.lang.Object

io.smallrye.reactive.messaging.providers.impl.ConnectorConfig

All Implemented Interfaces:

org.eclipse.microprofile.config.Config

public class ConnectorConfig
extends Object
implements org.eclipse.microprofile.config.Config

Implementation of config used to configured the different messaging provider / connector.

Field Summary

Fields

Modifier and Type	Field	Description
static String	BROADCAST_PROPERTY	Name of the attribute configuring the broadcast on a connector.
static String	CHANNEL_ENABLED_PROPERTY	Name of the attribute checking if the channel is enabled (default) or disabled.
static String	MERGE_PROPERTY	Name of the attribute configuring the merge on a connector.

Fields inherited from interface org.eclipse.microprofile.config.Config

PROFILE, PROPERTY_EXPRESSIONS_ENABLED

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConnectorConfig(String prefix, org.eclipse.microprofile.config.Config overall, String channel)

Method Summary

Modifier and Type	Method	Description
Iterable<org.eclipse.microprofile.config.spi.ConfigSource>	getConfigSources()
org.eclipse.microprofile.config.ConfigValue	getConfigValue(String propertyName)
<T> Optional<org.eclipse.microprofile.config.spi.Converter<T>>	getConverter(Class<T> forType)
<T> Optional<T>	getOptionalValue(String propertyName, Class<T> propertyType)
Iterable<String>	getPropertyNames()	Gets the lists of config keys for the given connector.
<T> T	getValue(String propertyName, Class<T> propertyType)
<T> T	unwrap(Class<T> type)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.microprofile.config.Config

getOptionalValues, getValues

Field Detail

CHANNEL_ENABLED_PROPERTY

public static final String CHANNEL_ENABLED_PROPERTY

Name of the attribute checking if the channel is enabled (default) or disabled. The value must be either `true` or `false`.

See Also:

Constant Field Values

BROADCAST_PROPERTY

public static final String BROADCAST_PROPERTY

Name of the attribute configuring the broadcast on a connector.

See Also:

Constant Field Values

MERGE_PROPERTY

public static final String MERGE_PROPERTY

Name of the attribute configuring the merge on a connector.

See Also:

Constant Field Values

Constructor Detail

ConnectorConfig

protected ConnectorConfig(String prefix,
                          org.eclipse.microprofile.config.Config overall,
                          String channel)

Method Detail

getValue

public <T> T getValue(String propertyName,
                      Class<T> propertyType)

Specified by:

getValue in interface org.eclipse.microprofile.config.Config

getConfigValue

public org.eclipse.microprofile.config.ConfigValue getConfigValue(String propertyName)

Specified by:

getConfigValue in interface org.eclipse.microprofile.config.Config

getOptionalValue

public <T> Optional<T> getOptionalValue(String propertyName,
                                        Class<T> propertyType)

Specified by:

getOptionalValue in interface org.eclipse.microprofile.config.Config

getPropertyNames

public Iterable<String> getPropertyNames()

Gets the lists of config keys for the given connector. Note that the list contains property names from the config and env variables. It includes keys from the connector config and channel config.

Specified by:

getPropertyNames in interface org.eclipse.microprofile.config.Config

Returns:

the list of keys

getConfigSources

public Iterable<org.eclipse.microprofile.config.spi.ConfigSource> getConfigSources()

Specified by:

getConfigSources in interface org.eclipse.microprofile.config.Config

getConverter

public <T> Optional<org.eclipse.microprofile.config.spi.Converter<T>> getConverter(Class<T> forType)

Specified by:

getConverter in interface org.eclipse.microprofile.config.Config

unwrap

public <T> T unwrap(Class<T> type)

Specified by:

unwrap in interface org.eclipse.microprofile.config.Config