Package 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	Description
MqttServerConnectorIncomingConfiguration(org.eclipse.microprofile.config.Config config)	Creates a new MqttServerConnectorIncomingConfiguration.

Method Summary

Modifier and Type	Method	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