consumer.go

package main

import (
	"github.com/bitly/go-nsq"
	"log"
	"sync"
)

func main() {
	wg := &sync.WaitGroup{}
	wg.Add(1)

	config := nsq.NewConfig()
	q, _ := nsq.NewConsumer("goapi", "ch", config)
	q.AddHandler(nsq.HandlerFunc(func(msg *nsq.Message) error {
		log.Printf("Got a message(%d): %s", msg.Attempts, string(msg.Body))
		return nil
	}))

	err := q.ConnectToNSQD("130.211.139.218:14161")
	if err != nil {
		log.Panic("Could not connect")
	}
	wg.Wait()
}