gistfile1.txt

package main
 
import (
        "cloud.google.com/go/pubsub"
        "context"
        "net/http"
)
 
const (
        projectId      = "<PROJECT_ID>"
        topicId        = "<TOPIC_ID>"
        subscriptionId = "<SUBSCRIPTION_ID>"
)
 
func main() {
 
        // Reply to GAE healthchecks
        http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {})
        go http.ListenAndServe(":8080", nil)
 
        // Start a process pulling messages
        ctx := context.Background()
        client, _ := pubsub.NewClient(ctx, projectId)
 
        sub := client.Subscription(subscriptionId)
        _ = sub.Receive(ctx, func(ctx context.Context, m *pubsub.Message) {
                go func(m *pubsub.Message) {
                        // Handle the message here
                        m.Ack()
                }(m)
        })
}