B4A Library MQTT - MQ Telemetry Transport for B4A

Alberto Iglesias · Dec 14, 2014

This library was made based on MQTT Protocol

Installation instructions:
- Copy the .xml and .jar(s) files to your custom libraries folder
- Select in your REFERENCED LIBRARIES

Version history:
V1.0.0 (First public release - Donationware):
- Initial version

V1.0.2 (Release - Donationware):
- Implement method to get independence of threads

V1.0.4 (Release - Donationware):
- Implement method to subscribe a topic with QoS

V1.0.5 (Release - Donationware):
- Now can be used isConnected method "BEFORE" the first connection

V1.0.6 (Release - Donationware):
- not published

V1.0.7 (Release - Donationware):
- New methods: Publish2, Subscribe3, Subscribe4
This new methods return the token, then after when arrived or publish the messages, you can compare

MQTT
Author: Alberto Iglesias - alberto@visualnet.inf.br
Version: 1.07

MQTT
Events:
- connectionlost ( )
- deliverycomplete (Token As String)
- messageArrived (Topic As String, Message As String)
- onConnect (Status as boolean As )
- onDisconnect (Status as boolean As )
- onInitialized ( )
Fields:
- CleanSession As Boolean
- JavaDebug As Boolean
- KeepAliveInterval As Int
- QoS_AtLeastOnce As Int
- QoS_AtMostOnce As Int
- QoS_ExactlyOnce As Int
- generatedClientId As String
Methods:
- About As String
- Connect (broker As String, ClientID As String, Username As String, Password As String) As Boolean
- Disconnect As Boolean
- Initialize (eventname As String)
- Publish (Topic As String, Message As String, Qos As Int, Retained As Boolean)
- Publish2 (Topic AsString, Message AsString, Qos AsInt, Retained AsBoolean)
- Subscribe (Topic As String)
- Subscribe2 (Topic As String, QoS as int)
- Subscribe3 (Topic As String)
- Subscribe4 (Topic As String, QoS as int))
- Unsubscribe (Topic As String)
- Version As String
- isConnected As Boolean
Permissions:
- android.permission.ACCESS_WIFI_STATE
- android.permission.INTERNET

How works the MQTT protocol

Communication Infrastructure

References:
http://mqtt.org/
http://public.dhe.ibm.com/software/dw/webservices/ws-mqtt/mqtt-v3r1.html
Mosquitto Broker: http://mosquitto.org/

* This version is fully functional, the only one difference is when publishing a message the text "Donationware" is delivery with your message.
Please consider a simple €10 donation and I send to you the Library without "Donationware" text in a publish method.

Already available in B4J too:
https://www.b4x.com/android/forum/threads/mqtt-mq-telemetry-transport-for-b4j.48184/

Already available in B4i too:
https://www.b4x.com/android/forum/threads/mqtt-mq-telemetry-transport-for-b4i.50036/

manhof · Apr 29, 2016

Hello Alberto,

are you still active?

Alberto Iglesias · Apr 29, 2016

yes, of course!

engvidal · Aug 15, 2016

Hi Alberto
Can you help me ? I already use mqtt with MQTTlens, raspberry, PIC's, ESP8266, so I believe my environment is ok, but when I try to compile your sample for Android, i get this message?

Compiling generated Java code: Error
Cannot find C:\program files (x86)\Basic4android\libraries\org.eclipse;paho.client.mqttv3-1.0.1.jar

Thank You

Erel · Aug 15, 2016

Note that there is an official MQTT library: https://www.b4x.com/android/forum/threads/jmqtt-official-android-mqtt-client.59497/#content

Alberto Iglesias · Aug 15, 2016

its sound like you dont copy the .jar to the libraries....

engvidal · Aug 26, 2016

It is running now.
Very simple.
Just a question ? Where are you located ? I saw an answer in good portuguese. Are you in Brazil ??
I am asking because my credit card only accept US$ convertions, not euros.. Is there any way I can pay for it in US$ directly ?

Alberto Iglesias · Aug 26, 2016

Ola Vidal (engenheiro Vidal?)

Sou Brasileiro, mas moro na Espanha!

Não se preocupe quanto a conversão, o Paypal aceita qualquer moeda.

Já deu uma olhada na minha store? Veja aí:

http://vnsoft.es/store/

cas6678 · Oct 3, 2016

Hi Alberto.
I set your 1.07 library as you suggested.
Im trying to use "CloudMQTT"

B4X:

Dim strBroker As String    = "m10.cloudmqtt.com:17612"
   Dim strUsername As String  = "XXXXXXXX"
   Dim strPassword As String  = "XXXXXXXXX"
   Dim bRet As Boolean = objMqtt.Connect(strBroker,"1",strUsername,strPassword)

"1" might be Client ID, is right?
But each time i clicked Connect button i received this log error.
Could you suggest me what am i missing?

** Activity (main) Create, isFirst = true **
[objMqtt_onInitialized]
MQTT About = MQTT Library - By Alberto Iglesias (alberto@visualnet.inf.br)
MQTT Version = 1.0.7 ** DONATIONWARE **
** Activity (main) Resume **
Error occurred on line: 49 (Main)
java.lang.NullPointerException: Attempt to invoke virtual method 'boolean java.lang.String.equals(java.lang.Object)' on a null object reference
at org.eclipse.paho.client.mqttv3.MqttConnectOptions.validateURI(MqttConnectOptions.java:457)
at org.eclipse.paho.client.mqttv3.MqttAsyncClient.<init>(MqttAsyncClient.java:273)
at org.eclipse.paho.client.mqttv3.MqttAsyncClient.<init>(MqttAsyncClient.java:167)
at com.visualnet.mqtt.Connect(mqtt.java:313)
at com.visualnet.mqtttest.main._button1_click(main.java:433)
at java.lang.reflect.Method.invoke(Native Method)
at java.lang.reflect.Method.invoke(Method.java:372)
at anywheresoftware.b4a.shell.Shell.runMethod(Shell.java:703)
at anywheresoftware.b4a.shell.Shell.raiseEventImpl(Shell.java:337)
at anywheresoftware.b4a.shell.Shell.raiseEvent(Shell.java:247)
at java.lang.reflect.Method.invoke(Native Method)
at java.lang.reflect.Method.invoke(Method.java:372)
at anywheresoftware.b4a.ShellBA.raiseEvent2(ShellBA.java:134)
at anywheresoftware.b4a.BA.raiseEvent2(BA.java:157)
at anywheresoftware.b4a.BA.raiseEvent(BA.java:153)
at anywheresoftware.b4a.objects.ViewWrapper$1.onClick(ViewWrapper.java:78)
at android.view.View.performClick(View.java:5156)
at android.view.View$PerformClick.run(View.java:20755)
at android.os.Handler.handleCallback(Handler.java:739)
at android.os.Handler.dispatchMessage(Handler.java:95)
at android.os.Looper.loop(Looper.java:145)
at android.app.ActivityThread.main(ActivityThread.java:5832)
at java.lang.reflect.Method.invoke(Native Method)
at java.lang.reflect.Method.invoke(Method.java:372)
at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:1399)
at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:1194)

EDIT: Same issue with my RPi as MQTT broker running mosquitto at ip:1883.

Alberto Iglesias · Oct 4, 2016

I put exactly your server, pass and username and works very well, look my sample and screenshot

cas6678 · Oct 4, 2016

Now works well!!!
I need to compare your last Sample with the old one.
More questions when i find differences.
Thanks!!

Doñate · Jan 10, 2017

Hi Alnerto, I like your library, I test here: http://cloud.iot-playground.com/ and work very well when I publish and subscribe.

I will a make a donation later next week, when I do this, you still send me a library without "Donationware" right ?

Thanks in advance!

Alberto Iglesias · Jan 10, 2017

Hello my friend, yes exactly.

Take a look in

www.visualnet.inf.br/store

Best Regards!

amorosik · Oct 11, 2021

Hallo Alberto, I'm very interested in the communication topic via mqtt
Can you explain wich differences between official jMqtt library and your library?

Alberto Iglesias · Oct 11, 2021

Hello my friend, I'm not using B4x anymore, you can compare with this library, I create mine based on this: org.eclipse.paho.client.mqttv3

Eclipse Paho | The Eclipse Foundation

The Eclipse Foundation - home to a global community, the Eclipse IDE, Jakarta EE and over 415 open source projects, including runtimes, tools and frameworks.

www.eclipse.org

amorosik · Oct 11, 2021

Alberto Iglesias said:
Hello my friend, I'm not using B4x anymore, you can compare with this library, I create mine based on this: org.eclipse.paho.client.mqttv3

Eclipse Paho | The Eclipse Foundation

The Eclipse Foundation - home to a global community, the Eclipse IDE, Jakarta EE and over 415 open source projects, including runtimes, tools and frameworks.

www.eclipse.org

Also jMqtt is based on this project, then is difficult find pro/cons of jMqtt vs your library
"..I'm not using B4x anymore.." can we know if you have moved to other developer enviroment?

amorosik · Oct 11, 2021

Hi Alberto, could you tell me if your library, based on the Eclipse Paho project, allows automatic client reconnection, and high availability (alternative server use if main not available)?

B4A Library MQTT - MQ Telemetry Transport for B4A

Attachments

manhof

Member

Alberto Iglesias

Well-Known Member

engvidal

Member

Erel

B4X founder

Alberto Iglesias

Well-Known Member

engvidal

Member

Alberto Iglesias

Well-Known Member

cas6678

Active Member

Alberto Iglesias

Well-Known Member

Attachments

cas6678

Active Member

Doñate

New Member

Alberto Iglesias

Well-Known Member

amorosik

Expert

Alberto Iglesias

Well-Known Member

Eclipse Paho | The Eclipse Foundation

amorosik

Expert

Eclipse Paho | The Eclipse Foundation

amorosik

Expert

Similar Threads

B4A Library MQTT - MQ Telemetry Transport for B4A

Attachments

Member

Well-Known Member

Member

B4X founder

Well-Known Member

Member

Well-Known Member

Active Member

Well-Known Member

Attachments

Active Member

New Member

Well-Known Member

Expert

Well-Known Member

Expert

Expert

Similar Threads

Privacy & Transparency

Privacy & Transparency