Package io.smallrye.reactive.messaging.mqtt.server

Class MqttServerConnectorIncomingConfiguration

    • 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