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 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, getReconnectAttempts, getReconnectIntervalSeconds, getServerName, getSsl, getTopic, getTrustAll, getUsername, getWillFlag, getWillQos, getWillRetain
-
-
-
-
Method Detail
-
validate
public void validate()
- Overrides:
validate
in classMqttConnectorCommonConfiguration
-
-