Class MqttConnectorOutgoingConfiguration
- java.lang.Object
-
- io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration
-
- io.smallrye.reactive.messaging.mqtt.MqttConnectorOutgoingConfiguration
-
public class MqttConnectorOutgoingConfiguration extends MqttConnectorCommonConfiguration
Extract the outgoing configuration for thesmallrye-mqtt
connector.
-
-
Field Summary
-
Fields inherited from class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration
config
-
-
Constructor Summary
Constructors Constructor Description MqttConnectorOutgoingConfiguration(org.eclipse.microprofile.config.Config config)
Creates a new MqttConnectorOutgoingConfiguration.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Boolean
getMerge()
Gets the merge value from the configuration.void
validate()
-
Methods inherited from class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration
config, getAutoCleanSession, getAutoGeneratedClientId, getAutoKeepAlive, getChannel, getClientId, getConnectTimeoutSeconds, getFromAlias, getFromAliasWithDefaultValue, getHost, getKeepAliveSeconds, getMaxInflightQueue, getMaxMessageSize, getPassword, getPort, getQos, getReconnectIntervalSeconds, getServerName, getSsl, getSslKeystoreLocation, getSslKeystorePassword, getSslKeystoreType, getSslTruststoreLocation, getSslTruststorePassword, getSslTruststoreType, getTopic, getTrustAll, getUsername, getWillFlag, getWillQos, getWillRetain
-
-
-
-
Method Detail
-
getMerge
public Boolean getMerge()
Gets the merge value from the configuration. Attribute Name: merge Description: Whether the connector should allow multiple upstreams Default Value: false- Returns:
- the merge
-
validate
public void validate()
- Overrides:
validate
in classMqttConnectorCommonConfiguration
-
-