Per the instructions I have added this package, but I can't seem to import the module. Seems to work fine for an ios application. I must be missing something obvious. Is there anything I can try?

This is the relevant code in my swift code

import MQTTNIO

I'm using an MQTTClient. I want to subscribe and have a callback when I receive a message. I'm using version 2.0.0 (also tried with 2.6.0). This is for a watchOS app

If I do this

    init() {
        client.connect()
        
        client.whenMessage { message in
            print("Received: \(message)")
        }
    }

I get this Value of type 'MQTTClient' has no member 'whenMessage'

I am trying to connect to a broker on a watch app (WatchOS: 8.3) but I receive this error: Error while connecting ioOnClosedChannel

I have been looking trough the package to find something but I can't seem to find anything.

This is the code I use (with correct values for username, password and url filled in):

    let credentials = MQTTConfiguration.Credentials.init(username: "username", password: "password")
    
    let client = MQTTClient(configuration: .init(url: URL(string: "url")!, credentials: credentials))
    //client.connect()
    client.connect().whenComplete { result in
        switch result {
        case .success:
            print("Succesfully connected")
        case .failure(let error):
            print("Error while connecting \(error)")
        }
    }

Thanks in advance!

This fixes WebSocket connections to Mosquitto brokers disconnecting every 5 minutes due to the server not receiving any response to WebSocket ping frames. Mosquitto uses libwebsockets which defaults to sending a ping frame every 5 minutes with a 10 second timeout.

Hi

I am trying to upload my app to the app store connect using this package. But I'm getting this error when uploading:

ITMS-90562: Invalid Bundle - Bitcode failed to compile for your watchOS binary because it includes assembly source code or inline assembly.

I found that it is probably related to dependency on the Swift-NIO-SSL package. But haven't been able to work out a solution.

Maybe you have a solution to this problem.

Thanks in advance.

I have a below scenario where I don't receive old messages.

1. Device is currently in disconnected state
2. Send message A from Azure IoT Hub
3. Connect device to IoTHub
4. Not receiving old message A from step 2.

The current time out is 1 hour on IoT Hub side. Is there any settings or anything I need to do to get old messages. Thanks.

Hi, great project, thank you for your work! :)

From version 4.6 we are unable to pass client certificate chain, because client certificate is passed by SecIdentity and SecIndetity is unable to hold certificate chain. I have created PR to your project solving this problem: https://github.com/sroebert/mqtt-nio/pull/10

I asked Apple engineer about my solution and he confirmed that this is correct solution: https://developer.apple.com/forums/thread/715174

All tests passed.

Hey,

I have integrated the MQTT NIO version 2.5.0 to my current watch OS target. Everything works fine I am able to access the API during my development. But I am facing an Xcode crash while exporting IPA from Archive.

1. Running on the device and simulator --> No issues
2. Archiving is successful.

3) Exporting IPA from Archive --> Xcode is crashing. I have tested with other package dependencies, i am able to export IPA successfully.

Please do the needful

Hi,

I've been testing MQTT libraries for Swift for the past two days and this repo appears to be the only Swift library which supports wss. Nice work!

Issues: I received the log: "notice nl.roebert.MQTTNio : Disconnected while waiting for 'Connect Acknowledgement'"

1. Is there a callback to alert the application when an error like this occurs?

2. I'm not sure how to resolve the issue. The url is a pre-signed AWS url with query string. I have the same working on Android with Eclipse.Paho. Looking at the MQTTConfiguration.swift I don't believe the query string is being included, is this a correct assumption? If that is correct is there any way to add the query string?

var client: MQTTClient! ..... //signed url url = wss://a2xxxxxxxx.iot.us-east-1.amazonaws.com/mqtt?X-Amz-Algori....... ... client = MQTTClient(configuration: .init(url: url, clientId: clientId)) client.connect() Thanks

I got an MQTT client running on macOS, but when running the same code on Linux (Ubuntu 18.04 on a Raspberry Pi 3) the client.connect().wait() never succeeds or fails - it just hangs. Any guidance would be very helpful. Thanks!