sqs_sample.go

package main

import (
        "fmt"
        "time"

        "github.com/goamz/goamz/aws"
        "github.com/goamz/goamz/sqs"
        "github.com/k0kubun/pp"
)

func main() {
        auth := aws.Auth{
                AccessKey: "", //os.Getenv("TEST"),
                SecretKey: "", //os.Getenv("TEST"),
        }

        region := aws.Region{
                Name:        "localhost",
                SQSEndpoint: "http://localhost:9324",
        }

        conn := sqs.New(auth, region)
        fmt.Println(conn)

        q, err := conn.GetQueue("PushQueue")
        if err != nil {
                fmt.Errorf("error:", err.Error())
        }
        fmt.Println("queue:", q)
        for {
                rcv, err := q.ReceiveMessage(10)
                if err != nil {
                        fmt.Errorf("rcv error:", err.Error())
                }
                //pp.Println("receive:", rcv)
                for _, m := range rcv.Messages {
                        del, err := q.DeleteMessageUsingReceiptHandle(m.ReceiptHandle)
                        if err != nil {
                                fmt.Errorf("del error:", err.Error())
                                continue
                        }
                        pp.Println("receive:", m)
                        pp.Println("deleted:", del)
                }
                time.Sleep(100 * time.Millisecond)
        }
}