package main

import (
	"log"

	"app.yhyue.com/moapp/jybase/go-logger/logger"
	. "app.yhyue.com/moapp/message/config"
	"app.yhyue.com/moapp/message/handler"
	"github.com/nsqio/go-nsq"
)

func init() {
	logger.SetConsole(false)
	logger.SetRollingDaily("./logs", "message.log")
}

//
func main() {
	// Instantiate a consumer that will subscribe to the provided channel.
	config := nsq.NewConfig()
	consumer, err := nsq.NewConsumer("jy_event", "event", 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(&handler.Handler{})
	// 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 {}
}