Consumer-Naive-solution

naive.go

package main
import (
	nsq "github.com/nsqio/go-nsq"
)

func AddMongoDB(data){
	// your code for preprocessing and adding new value in mongoDB
}

var handleMessage = func(msg *nsq.Message) error {
	var data interface{}
	_ := json.Unmarshal(msg.Body, &data)

	AddMongoDB(data)
	return nil
}

func InitNsqConsumer(){
	nsqTopic := "dummy_topic"
	nsqChannel := "dummy_channel"

	consumer, err := nsq.NewConsumer(nsqTopic, nsqChannel, nsq.NewConfig())
	consumer.AddHandler(nsq.HandleFunc(handleMessage))

	err = consumer.ConnectToNSQLookupd("127.0.0.1:4161")
	if err != nil{
		log.Print("error connecting to nsqlookupd")
	}
}