added nats watchdog

main.go

@@ -152,11 +152,14 @@ func main() {
 
 	natsIsUnavailable = true
 	natsClosedChan = make(chan bool, 10000)
+
 	err := connectToNATS()
 	if err != nil {
 		log.Fatal(err)
 	}
 
+	go natsWatchdog(natsClosedChan)
+
 	// What should I do?
 	if config.RequestsFile != "" {
 		replayFile()