org.springframework.cloud.stream.app.mqtt.sink

Class MqttSinkProperties

java.lang.Object

org.springframework.cloud.stream.app.mqtt.sink.MqttSinkProperties

@Validated
 @ConfigurationProperties(value="mqtt")
public class MqttSinkProperties
extends Object

Properties for the Mqtt Sink.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
MqttSinkProperties()

Method Summary

Modifier and Type	Method and Description
String	getCharset()
@NotBlank @Size(min=1,max=23) String	getClientId()
@Range(min=0L,max=2L) int	getQos()
@NotBlank String	getTopic()
boolean	isAsync()
boolean	isRetained()
void	setAsync(boolean async)
void	setCharset(String charset)
void	setClientId(String clientId)
void	setQos(int qos)
void	setRetained(boolean retained)
void	setTopic(String topic)

Methods inherited from class java.lang.Object

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

Constructor Detail

MqttSinkProperties

public MqttSinkProperties()

Method Detail

getQos

@Range(min=0L,
       max=2L)
public @Range(min=0L,max=2L) int getQos()

isRetained

public boolean isRetained()

setQos

public void setQos(int qos)

setRetained

public void setRetained(boolean retained)

getClientId

@NotBlank
 @Size(min=1,
      max=23)
public @NotBlank @Size(min=1,max=23) String getClientId()

setClientId

public void setClientId(String clientId)

getTopic

@NotBlank
public @NotBlank String getTopic()

setTopic

public void setTopic(String topic)

getCharset

public String getCharset()

setCharset

public void setCharset(String charset)

isAsync

public boolean isAsync()

setAsync

public void setAsync(boolean async)