error handling for nats connection

main.go

@@ -548,7 +548,10 @@ func replayFile() {
 			req.Host = "demo.scraperwall.com"
 			req.CreatedAt = time.Now().UnixNano()
 
-			natsEC.Publish(config.NatsQueue, &req)
+			err = natsEC.Publish(config.NatsQueue, &req)
+			if err != nil {
+				log.Println(err)
+			}
 
 			if strings.Index(r[1], ".") < 0 {
 				hash := sha1.New()