MqttConnectorIncomingConfiguration (SmallRye Reactive Messaging 2.2.1 API)

java.lang.Object
- io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration
- - io.smallrye.reactive.messaging.mqtt.MqttConnectorIncomingConfiguration

public class MqttConnectorIncomingConfiguration
extends MqttConnectorCommonConfiguration

Extract the incoming configuration for the smallrye-mqtt connector.

Field Summary
- Fields inherited from class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration
  config

Constructor Summary

Constructors
Constructor Description

MqttConnectorIncomingConfiguration(org.eclipse.microprofile.config.Config config)
Creates a new MqttConnectorIncomingConfiguration.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`Boolean`	`getBroadcast()`	Gets the broadcast value from the configuration.
`String`	`getFailureStrategy()`	Gets the failure-strategy 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, getReconnectAttempts, getReconnectIntervalSeconds, getServerName, getSsl, getTopic, getTrustAll, getUsername, getWillFlag, getWillQos, getWillRetain

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - MqttConnectorIncomingConfiguration
```
public MqttConnectorIncomingConfiguration(org.eclipse.microprofile.config.Config config)
```
    Creates a new MqttConnectorIncomingConfiguration.
- Method Detail
  - getBroadcast
```
public Boolean getBroadcast()
```
    Gets the broadcast value from the configuration. Attribute Name: broadcast Description: Whether or not the messages should be dispatched to multiple consumers Default Value: false
    
    Returns:
    
    the broadcast
  - getFailureStrategy
```
public String getFailureStrategy()
```
    Gets the failure-strategy value from the configuration. Attribute Name: failure-strategy Description: Specify the failure strategy to apply when a message produced from a MQTT message is nacked. Values can be `fail` (default), or `ignore` Default Value: fail
    
    Returns:
    
    the failure-strategy
  - validate
```
public void validate()
```
    Overrides:
    
    validate in class MqttConnectorCommonConfiguration