io.micronaut.mqtt.v5.config

Class MqttClientConfigurationProperties

java.lang.Object

io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties

All Implemented Interfaces:

MqttSSLConfiguration

@ConfigurationProperties(value="mqtt.client")
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.v5.config.MqttClientConfigurationProperties.WillMessage willMessage)

Method Summary

Modifier and Type	Method and Description
@NotNull java.lang.String	getClientId()
java.time.Duration	getConnectionTimeout()
org.eclipse.paho.mqttv5.client.MqttConnectionOptions	getConnectOptions()
@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	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.v5.config.MqttClientConfigurationProperties.WillMessage willMessage)

Method Detail

getConnectOptions

public org.eclipse.paho.mqttv5.client.MqttConnectionOptions 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

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