io.micronaut.mqtt.v3.config

Class MqttClientConfigurationProperties

java.lang.Object

io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties

All Implemented Interfaces:

MqttSSLConfiguration

@ConfigurationProperties(value="mqtt.client")
 @Context
public class MqttClientConfigurationProperties
extends java.lang.Object
implements MqttSSLConfiguration

Configuration for the MQTT client.

Since:

1.0.0

Author:

James Kleeh

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

MqttClientConfigurationProperties

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

Method Detail

getConnectOptions

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

Returns:

The connection options

getServerUri

@NotNull
public @NotNull java.lang.String getServerUri()

Returns:

The server URI

setServerUri

public void setServerUri(java.lang.String serverUri)

Parameters:

serverUri - The server URI

getClientId

@NotNull
public @NotNull java.lang.String getClientId()

Returns:

The client id

setClientId

public void setClientId(java.lang.String clientId)

Parameters:

clientId - The client ID

getConnectionTimeout

public java.time.Duration getConnectionTimeout()

Returns:

The connection timeout

setConnectionTimeout

public void setConnectionTimeout(java.time.Duration connectionTimeout)

Parameters:

connectionTimeout - How long to wait for a connection

getManualAcks

public java.util.Optional<java.lang.Boolean> getManualAcks()

Returns:

An optional boolean to set the client in manual acknowledge mode

setManualAcks

public void setManualAcks(java.lang.Boolean manualAcks)

Parameters:

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

getSocketFactory

public javax.net.SocketFactory getSocketFactory()

Specified by:

getSocketFactory in interface MqttSSLConfiguration

setSocketFactory

public void setSocketFactory(javax.net.SocketFactory socketFactory)

Specified by:

setSocketFactory in interface MqttSSLConfiguration

getSSLProperties

public java.util.Properties getSSLProperties()

Specified by:

getSSLProperties in interface MqttSSLConfiguration

setSSLProperties

public void setSSLProperties(java.util.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 javax.net.ssl.HostnameVerifier getSSLHostnameVerifier()

Specified by:

getSSLHostnameVerifier in interface MqttSSLConfiguration

setSSLHostnameVerifier

public void setSSLHostnameVerifier(javax.net.ssl.HostnameVerifier hostnameVerifier)

Specified by:

setSSLHostnameVerifier in interface MqttSSLConfiguration