Skip to content

Commit

Permalink
missing changes
Browse files Browse the repository at this point in the history
  • Loading branch information
somolinosm authored and adrianpozueco committed Jul 7, 2021
1 parent 0c2d8a4 commit d4dd0df
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 5 deletions.
5 changes: 3 additions & 2 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,10 @@ module github.com/Ryanair/goetlib
go 1.16

require (
github.com/Ryanair/gofrlib v1.0.5 // indirect
github.com/Ryanair/gofrlib v1.0.5
github.com/aws/aws-lambda-go v1.24.0
github.com/aws/aws-sdk-go v1.38.63
github.com/kr/pretty v0.2.1 // indirect
github.com/stretchr/testify v1.7.0
go.uber.org/zap v1.17.0
go.uber.org/zap v1.17.0 // indirect
)
6 changes: 3 additions & 3 deletions sqsClient/sqsClient.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ package sqsClient

import (
"errors"
"github.com/Ryanair/goetlib/logger"
"github.com/Ryanair/gofrlib/log"
"github.com/aws/aws-lambda-go/events"
"github.com/aws/aws-sdk-go/service/sqs"
"strings"
Expand Down Expand Up @@ -35,10 +35,10 @@ func (scheduler *SqsPublisher) Publish(body string) error {
QueueUrl: scheduler.queueUrl,
}

logger.Debug("Sending message to SQS: %+v", input)
log.Debug("Sending message to SQS: %+v", input)
_, err := scheduler.client.SendMessage(input)
if err != nil {
logger.Error("Error sending message %+v caused error %+v", input, err)
log.Error("Error sending message %+v caused error %+v", input, err)
return err
}
return nil
Expand Down

0 comments on commit d4dd0df

Please sign in to comment.