diff --git a/README.md b/README.md
index 3409de4..2e371ee 100644
--- a/README.md
+++ b/README.md
@@ -57,8 +57,8 @@
 
 #### from uiotedgedriverlinksdk.nats
 
-- **[natsPublish()](#register)**
-- **[natsSubscribe()](#set_on_topo_change_callback)**
+- **[natsPublish()](#natsPublish)**
+- **[natsSubscribe()](#natsSubscribe)**
 
 ---
 
diff --git a/iotedgedriverlinksdk/nats.py b/iotedgedriverlinksdk/nats.py
index 66ed2da..8557834 100644
--- a/iotedgedriverlinksdk/nats.py
+++ b/iotedgedriverlinksdk/nats.py
@@ -167,13 +167,20 @@ def natsSubscribe(subject, queue, cb):
 
 def _start_pub():
     _natsClientPub().start()
-    _natsClientPub().start()
+
+
+def _nats_pub():
+    _natsPublish().start()
 
 
 def _start_sub():
     _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.setDaemon(True)
 _t_nats_pub.start()