Metadata-Version: 2.1
Name: mqttsn
Version: 0.0.2
Summary: Python client based on Eclipse RSMB client for MQTT-SN brokers
Home-page: https://github.com/luanguimaraesla/mqttsn
Author: Luan Guimarães Lacerda
Author-email: luan@live.in
License: MIT License
Keywords: iot,mosquitto,mqtt,mqttsn,mqtt-sn,message,queue,pipeline,sensors,network,udp,protocol
Platform: UNKNOWN
Classifier: Development Status :: 3 - Alpha
Classifier: Intended Audience :: Developers
Classifier: Operating System :: POSIX
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3.6
Classifier: Topic :: Software Development :: Libraries
Provides-Extra: docs
Provides-Extra: dev
Requires-Dist: paho-mqtt
Provides-Extra: dev
Requires-Dist: pytest; extra == 'dev'
Requires-Dist: pytest-cov; extra == 'dev'
Requires-Dist: coverage; extra == 'dev'
Requires-Dist: flake8; extra == 'dev'
Requires-Dist: bumpversion; extra == 'dev'
Provides-Extra: docs
Requires-Dist: docutils; extra == 'docs'
Requires-Dist: sphinx-autobuild; extra == 'docs'

## Python Client for MQTT-SN brokers

### Usage examples

```python
from mqttsn.client import Client, Callback

import sys


class MyCallback(Callback):
    def message_arrived(self, topic_name, payload, qos, retained, msgid):
        print(f'{self} | topic_name: {topic_name} | payload: {payload} | '
              f'qos {qos} | retained {retained} | msgid {msgid}',
              file=sys.stderr)

        return True


if __name__ == '__main__':
    aclient = Client("linh", port=1883)
    aclient.register_callback(MyCallback())
    aclient.connect()

    rc, topic1 = aclient.subscribe("topic1")
    print("topic id for topic1 is", topic1)

    rc, topic2 = aclient.subscribe("topic2")
    print("topic id for topic2 is", topic2)

    aclient.publish(topic1, "aaaa", qos=0)
    aclient.publish(topic2, "bbbb", qos=0)

    aclient.unsubscribe("topic1")

    aclient.publish(topic2, "cccc", qos=0)
    aclient.publish(topic1, "dddd", qos=0)

    aclient.disconnect()
```


