summaryrefslogtreecommitdiff
path: root/bookpipeline
diff options
context:
space:
mode:
authorNick White <git@njw.name>2019-09-23 16:39:13 +0100
committerNick White <git@njw.name>2019-09-23 16:39:13 +0100
commit565fd83952af7001c2f720ef6fe5b0fc3bf8cf17 (patch)
treea84618669dee4ccc8fbc82dd3740df36d329d8fc /bookpipeline
parent933aa3bf976f66d2a184922aff613c2b22fdca1b (diff)
gofmt
Diffstat (limited to 'bookpipeline')
-rw-r--r--bookpipeline/aws.go10
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))