c
org.apache.pekko.stream.connectors.mqttv5
MqttConnectionSettings
Companion object MqttConnectionSettings
final class MqttConnectionSettings extends AnyRef
Connection settings passed to the underlying Paho client.
Java docs for MqttConnectionOptions are not available;
see https://github.com/eclipse-paho/paho.mqtt.java/issues/1012 or
org.eclipse.paho.mqttv5.client.MqttConnectionOptions for more info
- Source
 - settings.scala
 
Linear Supertypes
Ordering
- Alphabetic
 - By Inheritance
 
Inherited
- MqttConnectionSettings
 - AnyRef
 - Any
 
- Hide All
 - Show All
 
Visibility
- Public
 - Protected
 
Value Members
-   final  def !=(arg0: Any): Boolean
- Definition Classes
 - AnyRef → Any
 
 -   final  def ##: Int
- Definition Classes
 - AnyRef → Any
 
 -   final  def ==(arg0: Any): Boolean
- Definition Classes
 - AnyRef → Any
 
 -   final  def asInstanceOf[T0]: T0
- Definition Classes
 - Any
 
 -  def asMqttConnectionOptions(): MqttConnectionOptions
 -  val auth: AuthSettings
 -  val automaticReconnect: Boolean
 -  val broker: String
 -  val cleanStart: CleanStartSettings
 -  val clientId: String
 -    def clone(): AnyRef
- Attributes
 - protected[lang]
 - Definition Classes
 - AnyRef
 - Annotations
 - @throws(classOf[java.lang.CloneNotSupportedException]) @native()
 
 -  val connectionTimeout: FiniteDuration
 -  val disconnect: DisconnectSettings
 -   final  def eq(arg0: AnyRef): Boolean
- Definition Classes
 - AnyRef
 
 -    def equals(arg0: AnyRef): Boolean
- Definition Classes
 - AnyRef → Any
 
 -    def finalize(): Unit
- Attributes
 - protected[lang]
 - Definition Classes
 - AnyRef
 - Annotations
 - @throws(classOf[java.lang.Throwable])
 
 -   final  def getClass(): Class[_ <: AnyRef]
- Definition Classes
 - AnyRef → Any
 - Annotations
 - @native()
 
 -    def hashCode(): Int
- Definition Classes
 - AnyRef → Any
 - Annotations
 - @native()
 
 -   final  def isInstanceOf[T0]: Boolean
- Definition Classes
 - Any
 
 -  val keepAliveInterval: FiniteDuration
 -   final  def ne(arg0: AnyRef): Boolean
- Definition Classes
 - AnyRef
 
 -   final  def notify(): Unit
- Definition Classes
 - AnyRef
 - Annotations
 - @native()
 
 -   final  def notifyAll(): Unit
- Definition Classes
 - AnyRef
 - Annotations
 - @native()
 
 -  val offlinePersistence: Option[MqttOfflinePersistenceSettings]
 -  val persistence: MqttClientPersistence
 -  val serverUris: Array[String]
 -  val socketFactory: Option[SSLSocketFactory]
 -  val sslHostnameVerifier: Option[HostnameVerifier]
 -  val sslProperties: Map[String, String]
 -   final  def synchronized[T0](arg0: => T0): T0
- Definition Classes
 - AnyRef
 
 -    def toString(): String
- Definition Classes
 - MqttConnectionSettings → AnyRef → Any
 
 -   final  def wait(): Unit
- Definition Classes
 - AnyRef
 - Annotations
 - @throws(classOf[java.lang.InterruptedException])
 
 -   final  def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
 - AnyRef
 - Annotations
 - @throws(classOf[java.lang.InterruptedException])
 
 -   final  def wait(arg0: Long): Unit
- Definition Classes
 - AnyRef
 - Annotations
 - @throws(classOf[java.lang.InterruptedException]) @native()
 
 -  val will: Option[MqttMessage]
 -    def withAuth(method: String, initialData: Array[Byte], authPacketHandler: BiFunction[Int, MqttProperties, Pair[Int, MqttProperties]]): MqttConnectionSettings
Java API
 -    def withAuth(method: String, initialData: Array[Byte], authPacketHandler: (Int, MqttProperties) => (Int, MqttProperties)): MqttConnectionSettings
Scala API
 -  def withAuth(username: String, password: String): MqttConnectionSettings
 -  def withAutomaticReconnect(value: Boolean): MqttConnectionSettings
 -  def withBroker(value: String): MqttConnectionSettings
 -    def withCleanStart(enabled: Boolean, sessionExpiration: Duration): MqttConnectionSettings
Java API
 -    def withCleanStart(enabled: Boolean, sessionExpiration: Option[FiniteDuration]): MqttConnectionSettings
Scala API
 -  def withCleanStart(enabled: Boolean): MqttConnectionSettings
 -  def withClientId(value: String): MqttConnectionSettings
 -    def withConnectionTimeout(value: Duration): MqttConnectionSettings
Java API
 -    def withConnectionTimeout(value: FiniteDuration): MqttConnectionSettings
Scala API
 -    def withDisconnectQuiesceTimeout(value: Duration): MqttConnectionSettings
Java API
 -    def withDisconnectQuiesceTimeout(value: FiniteDuration): MqttConnectionSettings
Scala API
 -    def withDisconnectTimeout(value: Duration): MqttConnectionSettings
Java API
 -    def withDisconnectTimeout(value: FiniteDuration): MqttConnectionSettings
Scala API
 -    def withKeepAliveInterval(value: Duration): MqttConnectionSettings
Java API
 -    def withKeepAliveInterval(value: FiniteDuration): MqttConnectionSettings
Scala API
 -  def withOfflinePersistenceSettings(bufferSize: Int = 5000, deleteOldestMessage: Boolean = false, persistBuffer: Boolean = true): MqttConnectionSettings
 -  def withPersistence(value: MqttClientPersistence): MqttConnectionSettings
 -  def withServerUri(value: String): MqttConnectionSettings
 -    def withServerUris(value: List[String]): MqttConnectionSettings
Java API
 -    def withServerUris(value: Seq[String]): MqttConnectionSettings
Scala API
 -  def withSocketFactory(value: SSLSocketFactory): MqttConnectionSettings
 -  def withSslHostnameVerifier(value: HostnameVerifier): MqttConnectionSettings
 -    def withSslProperties(value: Map[String, String]): MqttConnectionSettings
Java API
 -    def withSslProperties(value: Map[String, String]): MqttConnectionSettings
Scala API
 -  def withWill(value: MqttMessage): MqttConnectionSettings