@@ -261,7 +261,9 @@ func apacheLogCapture(logfile string) {
log.Printf("[%s] %s\n", request.Source, request.Url)
}
- natsEC.Publish(config.NatsQueue, &request)
+ if err := natsEC.Publish(config.NatsQueue, &request); err != nil {
+ log.Println(err)
+ }