Android Question [IoT] MQTT Protocol string issue from cloud

[Danbicky]

Hi Guys,

I am using the JMQTT library Version 1 and the basic draw canvas example.

This connects to my VPS running mosquitto and authenticates perfectly, the problem is when it receives a string message "clear" it throws a java io error.
Any ideas on how this can be solved?

Dim obj As Object = serializator.ConvertBytesToObject(Payload) '<---fails here

My global aim for this application is to create a MQTT android app running as a service and to be able to respond to notifications by bringing up a pop up with notification information and to also send messages back to the broker to control embedded devices connected.

Any input on this would be great, or if anyone has a simple MQTT service example that would be brilliant.

Massive thanks

Dans

 

[Erel]

1. Moved to the questions forum.
2. Please use [code]code here...[/code] tags when posting code.
3. Where is the code that sends the message?

 

[Danbicky]

Hi Erel,

I am using your canvas example for the client connected to my MQTT broker. The client publishing the string "clear" is node red on my vps server, all of my embedded nodes are able to receive this information from the subscribed topic, your default canvas app throws an error when any string message is received from my vps mosquito broker:

your default code that throws the error is:

Private Sub mqtt_MessageArrived (Topic As String, Payload() As Byte)
    If Topic = "danbicks" Then
        Log(BytesToString(Payload, 0, password.Length, "utf8"))
        Return
    End If
    Dim obj As Object = serializator.ConvertBytesToObject(Payload)
    If obj Is CircleData Then
        If Topic = mytopic Then Return 'the circle was already drawn
        Dim cd As CircleData = obj
        DrawCircleData(cd)
    Else 'obj is string
        Dim s As String = obj
        Select s
            Case "clear"
                Canvas1.ClearRect(0, 0, Canvas1.Width, Canvas1.Height)
            Case "close"
                MainForm.Close
        End Select
    End If
End Sub

I will do more tests and see where it is falling over, your B4J gives me a different error:java.util.zip.ZipException: incorrect header check

Dans

 

[Erel]

B4XSerializator can only deserialize messages that were previously serialized with B4XSerializator.
This is not the case here.

You need to use BytesToString to convert the bytes to a string.

 

[Danbicky]

Do you know of any examples that run as a service for MQTT that I could try?

Brilliant I will modify the code and see if I can get it working.

Thanks

Dans

 

[Erel]

The code is simple:

Private Sub mqtt_MessageArrived (Topic As String, Payload() As Byte)
        Log("Message arrived: " & BytesToString(Payload, 0, Payload.Length, "utf8"))
End Sub

Edit: Fixed the length issue.

 

[Danbicky]

Erel,

Thanks buddy for the example, I need to re focus with B4A, have not used it for some time been dabbling in C so simple mistakes. I have however modified your example which does compile, I have opted to use B4J for test purpose and now get an index out of bounds error, getting there!

java.lang.StringIndexOutOfBoundsException: String index out of range: 9

New modified routine!

Private Sub mqtt_MessageArrived (Topic As String, Payload() As Byte)
    If Topic = "danbicks" Then
        Log(BytesToString(Payload, 0, password.Length, "utf8")) >> BOMBS OUT HERE INDEX ERROR
       
        Dim VarString As String = BytesToString(Payload, 0, password.Length, "utf8")
       
        Select VarString
            Case "clear"
                Log("Woop Woop")
            Case "close"
                Log("Close received")
        End Select
       
        Return
        End If
End Sub

 

[udg]

In bytestostring you should use payload.length not pasword.length
sorry to be so short with my reply but using a tablet virtual keyboard is boring and prone to many errors

 

[Danbicky]

Thanks udg, Awesome works Woooo.

I have a lot to learn about B4 platform, time to start tinkering and progressing.

Regards

Dans