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-mqttconnector.
-
-
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 BooleangetMerge()Gets the merge value from the configuration.voidvalidate()-
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:
validatein classMqttConnectorCommonConfiguration
-
-