diff --git a/protocol/udp.go b/protocol/udp.go index c977919..aaa7e32 100644 --- a/protocol/udp.go +++ b/protocol/udp.go @@ -141,7 +141,7 @@ func (u *udpListener) Start() error { "peer": fmt.Sprintf("%v:%v", peer.IP.String(), peer.Port), }).Error(err) } - return + continue } if len(line) > 0 { line = line[:len(line)-1] // removes trailing '/n' diff --git a/relay/relay.go b/relay/relay.go index f0c1ac1..3c99305 100644 --- a/relay/relay.go +++ b/relay/relay.go @@ -69,12 +69,10 @@ func (r *relay) StreamMetrics(ctx context.Context, metrics_in chan []plugin.Metr if metric.Namespace[len(metric.Namespace)-1].Value == "collectd" { if val, err := metric.Config.GetString("collectdPort"); err == nil { metrics[idx].Data = val - log.Debug("collectdPort set to: %v", val) } } else if metric.Namespace[len(metric.Namespace)-1].Value == "statsd" { if val, err := metric.Config.GetString("statsdPort"); err == nil { metrics[idx].Data = val - log.Debug("statsdPort set to: %v", val) } }