io.smallrye.reactive.messaging.mqtt.server

Class MqttServerConnectorIncomingConfiguration

java.lang.Object

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

io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorIncomingConfiguration

public class MqttServerConnectorIncomingConfiguration
extends MqttServerConnectorCommonConfiguration

Extract the incoming configuration for the smallrye-mqtt-server connector.

Field Summary

Fields inherited from class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorCommonConfiguration

config

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Boolean	getAutoGeneratedClientId() Gets the auto-generated-client-id value from the configuration.
Boolean	getBroadcast() Gets the broadcast value from the configuration.
String	getHost() Gets the host value from the configuration.
Integer	getMaxMessageSize() Gets the max-message-size value from the configuration.
Optional<Integer>	getPort() Gets the port value from the configuration.
Integer	getReceiveBufferSize() Gets the receive-buffer-size value from the configuration.
Boolean	getSsl() Gets the ssl value from the configuration.
Integer	getTimeoutOnConnect() Gets the timeout-on-connect value from the configuration.
void	validate()

Methods inherited from class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorCommonConfiguration

config, getChannel, getFromAlias, getFromAliasWithDefaultValue

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MqttServerConnectorIncomingConfiguration

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

Creates a new MqttServerConnectorIncomingConfiguration.

Method Detail

getAutoGeneratedClientId

public Boolean getAutoGeneratedClientId()

Gets the auto-generated-client-id value from the configuration. Attribute Name: auto-generated-client-id Description: Set if the MQTT server must generate clientId automatically Default Value: true

Returns:

the auto-generated-client-id

getSsl

public Boolean getSsl()

Gets the ssl value from the configuration. Attribute Name: ssl Description: Set whether SSL/TLS is enabled Default Value: false

Returns:

the ssl

getMaxMessageSize

public Integer getMaxMessageSize()

Gets the max-message-size value from the configuration. Attribute Name: max-message-size Description: Set max MQTT message size. -1 means no limit Default Value: -1

Returns:

the max-message-size

getTimeoutOnConnect

public Integer getTimeoutOnConnect()

Gets the timeout-on-connect value from the configuration. Attribute Name: timeout-on-connect Description: Connect timeout in seconds Default Value: 90

Returns:

the timeout-on-connect

getReceiveBufferSize

public Integer getReceiveBufferSize()

Gets the receive-buffer-size value from the configuration. Attribute Name: receive-buffer-size Description: The receive buffer size Default Value: -1

Returns:

the receive-buffer-size

getHost

public String getHost()

Gets the host value from the configuration. Attribute Name: host Description: Set the MQTT server host name/IP Default Value: 0.0.0.0

Returns:

the host

getPort

public Optional<Integer> getPort()

Gets the port value from the configuration. Attribute Name: port Description: Set the MQTT server port. Default to 8883 if ssl is enabled, or 1883 without ssl

Returns:

the port

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

validate

public void validate()

Overrides:

validate in class MqttServerConnectorCommonConfiguration