add Network error event handler to subscriber example

iwanbk · Apr 30, 2012 · 41bc5c6 · 41bc5c6
1 parent c3c0ad0
commit 41bc5c6
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/test/subnya.py b/test/subnya.py
@@ -59,7 +59,14 @@ def start_nyamuk(server, client_id, topic, username = None, password = None):
                 handle_publish(ev)
             elif ev.type == NC.CMD_SUBACK:
                 handle_suback(ev)
+            elif ev.type == EV_NET_ERR:
+                print "Network Error. Msg = ", ev.msg
+                sys.exit(-1)
         rc = ny.loop()
+        if rc == NC.ERR_CONN_LOST:
+            ny.logger.fatal("Connection to server closed")
+
+    ny.logger.info("subscriber exited")
 
 if __name__ == '__main__':
     if len(sys.argv) != 4: