diff --git a/src/zmqrouter/main.go b/src/zmqrouter/main.go index 800a3fd..77ba7c5 100644 --- a/src/zmqrouter/main.go +++ b/src/zmqrouter/main.go @@ -4,6 +4,7 @@ import ( "encoding/json" "fmt" "log" + "time" "git.paulbsd.com/paulbsd/ipbl/src/config" "git.paulbsd.com/paulbsd/ipbl/src/models" @@ -49,6 +50,7 @@ func Handle(cfg *config.Config, reqsock *goczmq.Sock, pubsock *goczmq.Sock, chan err = json.Unmarshal(val, &apievent) if err != nil { log.Println("unable to parse ip address", err) + time.Sleep(time.Second) continue } if apievent.IPData.IP != "" && apievent.IPData.IP == lastip {