diff options
| author | Nick White <git@njw.name> | 2019-09-23 16:39:13 +0100 |
|---|---|---|
| committer | Nick White <git@njw.name> | 2019-09-23 16:39:13 +0100 |
| commit | 565fd83952af7001c2f720ef6fe5b0fc3bf8cf17 (patch) | |
| tree | a84618669dee4ccc8fbc82dd3740df36d329d8fc /bookpipeline | |
| parent | 933aa3bf976f66d2a184922aff613c2b22fdca1b (diff) | |
gofmt
Diffstat (limited to 'bookpipeline')
| -rw-r--r-- | bookpipeline/aws.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/bookpipeline/aws.go b/bookpipeline/aws.go index 689f1b2..f3cdbfa 100644 --- a/bookpipeline/aws.go +++ b/bookpipeline/aws.go @@ -102,8 +102,8 @@ func (a *AwsConn) CheckQueue(url string, timeout int64) (Qmsg, error) { if len(msgResult.Messages) > 0 { msg := Qmsg{Id: *msgResult.Messages[0].MessageId, - Handle: *msgResult.Messages[0].ReceiptHandle, - Body: *msgResult.Messages[0].Body} + Handle: *msgResult.Messages[0].ReceiptHandle, + Body: *msgResult.Messages[0].Body} a.Logger.Println("Message received:", msg.Body) return msg, nil } else { @@ -150,9 +150,9 @@ func (a *AwsConn) QueueHeartbeat(msg Qmsg, qurl string, duration int64) (Qmsg, e for _, m := range msgResult.Messages { if *m.MessageId == msg.Id { return Qmsg{ - Id: *m.MessageId, + Id: *m.MessageId, Handle: *m.ReceiptHandle, - Body: *m.Body, + Body: *m.Body, }, nil } } @@ -172,7 +172,7 @@ func (a *AwsConn) GetQueueDetails(url string) (string, string, error) { numInProgress := "ApproximateNumberOfMessagesNotVisible" attrs, err := a.sqssvc.GetQueueAttributes(&sqs.GetQueueAttributesInput{ AttributeNames: []*string{&numAvailable, &numInProgress}, - QueueUrl: &url, + QueueUrl: &url, }) if err != nil { return "", "", errors.New(fmt.Sprintf("Failed to get queue attributes: %s", err)) |