IPWorks MQ 2020 Kotlin Edition

Questions / Feedback?

MessageIn Event

Fired when an incoming message has been received and/or fully acknowledged.

Syntax

public open class DefaultMqttEventListener : MqttEventListener {
  ...
  public override fun messageIn(e: MqttMessageInEvent) {}
  ...
}

public class MqttMessageInEvent {
  val packetId: Int
  val topic: String?
  val qos: Int
  val message: ByteArray?
  val retained: Boolean
  val duplicate: Boolean
}

Remarks

The MessageIn event fires once for each incoming message either immediately after it is received (QoS 0), or after it has been fully acknowledged (QoS 1 and 2).

  • PacketId: The message packet Id. This will always be -1 if QOS is 0.
  • Topic: The message's topic string.
  • QOS: The message's QoS level.
  • Message: The message data.
  • Retained: Whether or not this message was received as a result of subscribing to a topic.
  • Duplicate: Whether or not the server has indicated that this message is a duplicate of another message sent previously.

Refer to MessageAck for more information about QoS 1 and 2 message processing steps.


// MessageIn event handler.
mqtt1.OnMessageIn += (s, e) => {
  Console.WriteLine("Received message from topic '" + e.Topic + "' with QoS " + e.QOS + ":");
  Console.WriteLine(e.Message);
};

Copyright (c) 2021 /n software inc. - All rights reserved.
IPWorks MQ 2020 Kotlin Edition - Version 20.0 [Build 7941]