Skip to content
master
Switch branches/tags
Code

Latest commit

 

Git stats

Files

Permalink
Failed to load latest commit information.
Type
Name
Latest commit message
Commit time
 
 
src
 
 
 
 
 
 
 
 

MQTT-broker

An implementation of a MQTT Client and a Broker in pure Smalltalk for Pharo

This work is based on the work that Tim Rowledge wrote for the Pi The original code base is found at:

http://www.squeaksource.com/MQTTClient.html

What we did was refactor the logic into a client and server interface to support a full MQTT V311 data broker in pure Smalltalk. This product (in VSE) did pass various V311 data broker test units, after converting to Pharo we hope it still works.

To start the server. (MQTTServerInterface openOnPort: 1883) start inspect.

To start a client.
[(MQTTClientInterface openOnHostName: ‘192.168.1.139’ port: 1883 keepAlive: 300) start inspect] fork.
or
[(MQTTClientInterface openOnHostName: ‘test.mosquitto.org’ port: 1883 keepAlive: 300) start inspect] fork.

Stopping the server or the client.

MQTTServerInterface  allInstances do: [ :e | e stop ].
MQTTClientInterface  allInstances do: [ :e | e stop ].

Helpful for figuring out what is running, or not, ensure you do a GC before using.

MQTTSocketClient  allInstances  inspect.
MQTTClientInterface allInstances  inspect.
MQTTTransportLayerClient allInstances  inspect.
MQTTSocketServer  allInstances  inspect.
MQTTServerInterface allInstances inspect.
MQTTSocketDaemon allInstances inspect.
MQTTTransportLayerServer allInstances inspect.

If you examine the class MQTTStatistics we do collect statistics on each server and client session.

LOGGING is on To turn it off change the code found in MQTTCLientInterface class>>debugLog:tag:str2: (or: [true])

In MQTTCLientInterface there are methods testBlock and testSetupForTopic These can be alter to test for example a connection to test.mosquitto.org. At the moment they send QOS > 0 message info to the Transcript

Things that the community could do?

Persistent store of the data broker queued data
Ensure it works with Pharo
Port to VA Smalltalk
Port to other variations. 
Respecting userid & password in the Connect packet.
If you need a VSE version please contact us. 

About

An implementation of a MQTT Client and a Broker in pure Smalltalk for Pharo

Resources

License

Packages

No packages published