Package io.smallrye.reactive.messaging.mqtt.server

Class MqttServerConnectorCommonConfiguration

java.lang.Object

io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorCommonConfiguration

Direct Known Subclasses:

MqttServerConnectorIncomingConfiguration, MqttServerConnectorOutgoingConfiguration

public class MqttServerConnectorCommonConfiguration
extends Object

Extracts the common configuration for the smallrye-mqtt-server connector.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
MqttServerConnectorCommonConfiguration(org.eclipse.microprofile.config.Config config)	Creates a new MqttServerConnectorCommonConfiguration.

Method Summary

Modifier and Type	Method	Description
org.eclipse.microprofile.config.Config	config()
String	getChannel()
protected <T> Optional<T>	getFromAlias(String alias, Class<T> type)	Retrieves the value stored for the given alias.
protected <T> T	getFromAliasWithDefaultValue(String alias, Class<T> type, T defaultValue)	Retrieves the value stored for the given alias.
void	validate()

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

Constructor Detail

MqttServerConnectorCommonConfiguration

public MqttServerConnectorCommonConfiguration(org.eclipse.microprofile.config.Config config)

Creates a new MqttServerConnectorCommonConfiguration.

Method Detail

config

public org.eclipse.microprofile.config.Config config()

Returns:

the connector configuration

getFromAlias

protected <T> Optional<T> getFromAlias(String alias,
                                       Class<T> type)

Retrieves the value stored for the given alias.

Type Parameters:

T - the targeted type

Parameters:

alias - the attribute alias, must not be null or blank

type - the targeted type

Returns:

the configuration value for the given alias, empty if not set

getFromAliasWithDefaultValue

protected <T> T getFromAliasWithDefaultValue(String alias,
                                             Class<T> type,
                                             T defaultValue)

Retrieves the value stored for the given alias. Returns the default value if not present.

Type Parameters:

T - the targeted type

Parameters:

alias - the attribute alias, must not be null or blank

type - the targeted type

defaultValue - the default value

Returns:

the configuration value for the given alias, empty if not set

getChannel

public String getChannel()

Returns:

the channel name

validate

public void validate()