diff --git a/sda/cmd/ingest/ingest.go b/sda/cmd/ingest/ingest.go index 14b2ecc80..1b355eebb 100644 --- a/sda/cmd/ingest/ingest.go +++ b/sda/cmd/ingest/ingest.go @@ -116,7 +116,7 @@ func main() { body, _ := json.Marshal(infoErrorMessage) if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil { - log.Errorf("failed so publish message, reason: (%v)", err.Error()) + log.Errorf("failed to publish message, reason: (%v)", err.Error()) } if err := delivered.Ack(false); err != nil { log.Errorf("Failed acking canceled work, reason: (%v)", err.Error()) @@ -173,7 +173,7 @@ func main() { } body, _ := json.Marshal(fileError) if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil { - log.Errorf("failed so publish message, reason: (%v)", err.Error()) + log.Errorf("failed to publish message, reason: (%v)", err.Error()) } if err = delivered.Ack(false); err != nil { log.Errorf("Failed to Ack message, reason: (%v)", err.Error()) @@ -199,7 +199,7 @@ func main() { } body, _ := json.Marshal(fileError) if err = mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil { - log.Errorf("failed so publish message, reason: (%v)", err.Error()) + log.Errorf("failed to publish message, reason: (%v)", err.Error()) } // Restart on new message @@ -278,7 +278,7 @@ func main() { } body, _ := json.Marshal(fileError) if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil { - log.Errorf("failed so publish message, reason: (%v)", err.Error()) + log.Errorf("failed to publish message, reason: (%v)", err.Error()) } continue mainWorkLoop diff --git a/sda/cmd/verify/verify.go b/sda/cmd/verify/verify.go index 6f633b71d..706141805 100644 --- a/sda/cmd/verify/verify.go +++ b/sda/cmd/verify/verify.go @@ -82,7 +82,7 @@ func main() { body, _ := json.Marshal(infoErrorMessage) if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil { - log.Errorf("failed so publish message, reason: %v", err.Error()) + log.Errorf("failed to publish message, reason: %v", err.Error()) } if err := delivered.Ack(false); err != nil { log.Errorf("Failed to Ack message, reason: %v", err.Error()) @@ -113,7 +113,7 @@ func main() { body, _ := json.Marshal(infoErrorMessage) if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil { - log.Errorf("failed so publish message, reason: %v", err.Error()) + log.Errorf("failed to publish message, reason: %v", err.Error()) } if err := delivered.Ack(false); err != nil { @@ -151,7 +151,7 @@ func main() { // Send the message to an error queue so it can be analyzed. if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil { - log.Errorf("failed so publish message, reason: %v", err.Error()) + log.Errorf("failed to publish message, reason: %v", err.Error()) } continue @@ -257,7 +257,7 @@ func main() { body, _ := json.Marshal(infoErrorMessage) if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil { - log.Errorf("failed so publish message, reason: %v", err.Error()) + log.Errorf("failed to publish message, reason: %v", err.Error()) } if err := delivered.Ack(false); err != nil {