OrgUCloud/iotstack-driver-sdk-python
1
0
Fork 0
mirror of https://github.com/ucloud/iotstack-driver-sdk-python.git synced 2025-04-25 13:48:50 +08:00
Code Issues Projects Releases Wiki Activity

add nats api

Browse Source
This commit is contained in:
joy,zhou 2021-05-26 10:59:33 +08:00
parent 888231b933
commit e357a0eaa5
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
README.md
View File

@ -57,8 +57,8 @@
#### from uiotedgedriverlinksdk.nats #### from uiotedgedriverlinksdk.nats
- **[natsPublish()](#register)** - **[natsPublish()](#natsPublish)**
- **[natsSubscribe()](#set_on_topo_change_callback)** - **[natsSubscribe()](#natsSubscribe)**
--- ---

9
iotedgedriverlinksdk/nats.py
View File

@ -167,13 +167,20 @@ def natsSubscribe(subject, queue, cb):
def _start_pub(): def _start_pub():
_natsClientPub().start() _natsClientPub().start()
_natsClientPub().start()
def _nats_pub():
_natsPublish().start()
def _start_sub(): def _start_sub():
_natsClientSub().start() _natsClientSub().start()
_t_pub = threading.Thread(target=_nats_pub)
_t_pub.setDaemon(True)
_t_pub.start()
_t_nats_pub = threading.Thread(target=_start_pub) _t_nats_pub = threading.Thread(target=_start_pub)
_t_nats_pub.setDaemon(True) _t_nats_pub.setDaemon(True)
_t_nats_pub.start() _t_nats_pub.start()