Packages

object MqttSource

Java API

MQTT source factory.

Source
MqttSource.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MqttSource
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def atLeastOnce(settings: MqttConnectionSettings, subscriptions: MqttSubscriptions, bufferSize: Int): Source[MqttMessageWithAck, CompletionStage[Done]]

    Create a source subscribing to MQTT messages with a commit handle to acknowledge message reception.

    Create a source subscribing to MQTT messages with a commit handle to acknowledge message reception.

    The materialized value completes on successful connection to the MQTT broker.

    bufferSize

    max number of messages read from MQTT before back-pressure applies

  2. def atMostOnce(settings: MqttConnectionSettings, subscriptions: MqttSubscriptions, bufferSize: Int): Source[MqttMessage, CompletionStage[Done]]

    Create a source subscribing to MQTT messages (without a commit handle).

    Create a source subscribing to MQTT messages (without a commit handle).

    The materialized value completes on successful connection to the MQTT broker.

    bufferSize

    max number of messages read from MQTT before back-pressure applies