package nsq

import (
	"apsClient/conf"
	"apsClient/pkg/safe"
	"errors"
	"fmt"
)

func Init() error {
	if len(conf.Conf.NsqConf.NodeId) <= 0 {
		return errors.New("no NodeId")
	}

	if err := initProducer(); err != nil {
		return err
	}

	safe.Go(func() {
		_ = Consume(fmt.Sprintf("aps.%v.scheduleTask", conf.Conf.NsqConf.NodeId), "sensor01")
	})

	return nil
}