Package org.apache.beam.sdk.io.mqtt

Class MqttIO.ConnectionConfiguration

java.lang.Object

org.apache.beam.sdk.io.mqtt.MqttIO.ConnectionConfiguration

All Implemented Interfaces:

Serializable

Enclosing class:

MqttIO

public abstract static class MqttIO.ConnectionConfiguration
extends Object
implements Serializable

A POJO describing a MQTT connection.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ConnectionConfiguration()

Method Summary

Modifier and Type	Method	Description
static MqttIO.ConnectionConfiguration	create(String serverUri)
static MqttIO.ConnectionConfiguration	create(String serverUri, String topic)	Describe a connection configuration to the MQTT broker.
MqttIO.ConnectionConfiguration	withClientId(String clientId)	Set up the client ID prefix, which is used to construct a unique client ID.
MqttIO.ConnectionConfiguration	withPassword(String password)
MqttIO.ConnectionConfiguration	withServerUri(String serverUri)	Set up the MQTT broker URI.
MqttIO.ConnectionConfiguration	withTopic(String topic)	Set up the MQTT getTopic pattern.
MqttIO.ConnectionConfiguration	withUsername(String username)

Methods inherited from class java.lang.Object

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

Constructor Details

ConnectionConfiguration

public ConnectionConfiguration()

Method Details

create

public static MqttIO.ConnectionConfiguration create(String serverUri,
 String topic)

Describe a connection configuration to the MQTT broker. This method creates a unique random MQTT client ID.

Parameters:

serverUri - The MQTT broker URI.

topic - The MQTT getTopic pattern.

Returns:

A connection configuration to the MQTT broker.

create

public static MqttIO.ConnectionConfiguration create(String serverUri)

withServerUri

public MqttIO.ConnectionConfiguration withServerUri(String serverUri)

Set up the MQTT broker URI.

withTopic

public MqttIO.ConnectionConfiguration withTopic(String topic)

Set up the MQTT getTopic pattern.

withClientId

public MqttIO.ConnectionConfiguration withClientId(String clientId)

Set up the client ID prefix, which is used to construct a unique client ID.

withUsername

public MqttIO.ConnectionConfiguration withUsername(String username)

withPassword

public MqttIO.ConnectionConfiguration withPassword(String password)