message/main.go

package main

import (
	"log"

	. "app.yhyue.com/moapp/message/config"
	"app.yhyue.com/moapp/message/points"
	"github.com/nsqio/go-nsq"
)

func main() {
	// Instantiate a consumer that will subscribe to the provided channel.
	config := nsq.NewConfig()
	consumer, err := nsq.NewConsumer("jy_event", "points", config)
	if err != nil {
		log.Fatal(err)
	}

	// Set the Handler for messages received by this Consumer. Can be called multiple times.
	// See also AddConcurrentHandlers.
	consumer.AddHandler(&points.Points{})

	// Use nsqlookupd to discover nsqd instances.
	// See also ConnectToNSQD, ConnectToNSQDs, ConnectToNSQLookupds.
	err = consumer.ConnectToNSQLookupd(Config.Nsq.Address)
	if err != nil {
		log.Fatal(err)
	}

	// Gracefully stop the consumer.
	//consumer.Stop()
	select {}
}