Package io.micronaut.mqtt.v3.config

Class MqttClientConfigurationProperties

java.lang.Object

io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties

All Implemented Interfaces:

MqttSSLConfiguration

@ConfigurationProperties("mqtt.client")
public class MqttClientConfigurationProperties
extends Object
implements MqttSSLConfiguration

Configuration for the MQTT client.

Since:

1.0.0

Author:

James Kleeh

Constructor Summary

Constructors

Constructor	Description
MqttClientConfigurationProperties(io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties.WillMessage willMessage)

Method Summary

Modifier and Type	Method	Description
@NotNull String	getClientId()
Duration	getConnectionTimeout()
org.eclipse.paho.client.mqttv3.MqttConnectOptions	getConnectOptions()
Optional<Boolean>	getManualAcks()
@NotNull String	getServerUri()
SocketFactory	getSocketFactory()
HostnameVerifier	getSSLHostnameVerifier()
Properties	getSSLProperties()
boolean	isHttpsHostnameVerificationEnabled()
void	setClientId(String clientId)
void	setConnectionTimeout(Duration connectionTimeout)
void	setHttpsHostnameVerificationEnabled(boolean httpsHostnameVerificationEnabled)
void	setManualAcks(Boolean manualAcks)
void	setServerUri(String serverUri)
void	setSocketFactory(SocketFactory socketFactory)
void	setSSLHostnameVerifier(HostnameVerifier hostnameVerifier)
void	setSSLProperties(Properties props)

Methods inherited from class java.lang.Object

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

Constructor Details

MqttClientConfigurationProperties

public MqttClientConfigurationProperties(io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties.WillMessage willMessage)

Method Details

getConnectOptions

public org.eclipse.paho.client.mqttv3.MqttConnectOptions getConnectOptions()

Returns:

The connection options

getServerUri

@NotNull
public @NotNull String getServerUri()

Returns:

The server URI

setServerUri

public void setServerUri(String serverUri)

Parameters:

serverUri - The server URI

getClientId

@NotNull
public @NotNull String getClientId()

Returns:

The client id

setClientId

public void setClientId(String clientId)

Parameters:

clientId - The client ID

getConnectionTimeout

public Duration getConnectionTimeout()

Returns:

The connection timeout

setConnectionTimeout

public void setConnectionTimeout(Duration connectionTimeout)

Parameters:

connectionTimeout - How long to wait for a connection

getManualAcks

public Optional<Boolean> getManualAcks()

Returns:

An optional boolean to set the client in manual acknowledge mode

setManualAcks

public void setManualAcks(Boolean manualAcks)

Parameters:

manualAcks - Set to true if you wish to manually acknowledge messages

getSocketFactory

public SocketFactory getSocketFactory()

Specified by:

getSocketFactory in interface MqttSSLConfiguration

setSocketFactory

public void setSocketFactory(SocketFactory socketFactory)

Specified by:

setSocketFactory in interface MqttSSLConfiguration

getSSLProperties

public Properties getSSLProperties()

Specified by:

getSSLProperties in interface MqttSSLConfiguration

setSSLProperties

public void setSSLProperties(Properties props)

Specified by:

setSSLProperties in interface MqttSSLConfiguration

isHttpsHostnameVerificationEnabled

public boolean isHttpsHostnameVerificationEnabled()

Specified by:

isHttpsHostnameVerificationEnabled in interface MqttSSLConfiguration

setHttpsHostnameVerificationEnabled

public void setHttpsHostnameVerificationEnabled(boolean httpsHostnameVerificationEnabled)

Specified by:

setHttpsHostnameVerificationEnabled in interface MqttSSLConfiguration

getSSLHostnameVerifier

public HostnameVerifier getSSLHostnameVerifier()

Specified by:

getSSLHostnameVerifier in interface MqttSSLConfiguration

setSSLHostnameVerifier

public void setSSLHostnameVerifier(HostnameVerifier hostnameVerifier)

Specified by:

setSSLHostnameVerifier in interface MqttSSLConfiguration