message/main.go

package main

import (
	"log"

	"app.yhyue.com/moapp/jybase/go-logger/logger"
	. "app.yhyue.com/moapp/message/config"
	"app.yhyue.com/moapp/message/points"
	"app.yhyue.com/moapp/message/push"
	"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", "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)
	}

	//push
	config_push := nsq.NewConfig()
	consumer_push, err := nsq.NewConsumer("jy_event", "push", config_push)
	if err != nil {
		log.Fatal(err)
	}

	consumer_push.AddHandler(&push.Push{})

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

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