add inter log

db/mq/mynsq/consumer.go

@@ -139,11 +139,11 @@ func (t *topicInfo) connect(channelName string, nsqdAddr []string, debug bool) {
 			time.Sleep(time.Duration(sleepSeconds) * time.Second)
 			continue
 		}
-		// if debug {
-		// 	t.consumer.SetLogger(log., gonsq.LogLevelDebug)
-		// } else {
-		// 	t.consumer.SetLogger(fmt.GetLogger(), gonsq.LogLevelWarning)
-		// }
+		if debug {
+			t.consumer.SetLogger(&interLog{}, gonsq.LogLevelDebug)
+		} else {
+			t.consumer.SetLogger(&interLog{}, gonsq.LogLevelWarning)
+		}
 		fmt.Printf("连接nsqd(%v)成功\n", nsqdAddr)
 		break
 	}

db/mq/mynsq/nsq.go

@@ -1,6 +1,8 @@
 package mynsq
 
 import (
+	"fmt"
+
 	"github.com/cuigh/auxo/config"
 	"github.com/cuigh/auxo/errors"
 )
@@ -16,6 +18,14 @@ type Options struct {
 	ChannelName    string
 }
 
+type interLog struct {
+}
+
+func (il *interLog) Output(calldepth int, s string) error {
+	fmt.Println(s)
+	return nil
+}
+
 func loadOptions() (*Options, error) {
 	key := "global.mq.nsq"
 	if !config.Exist(key) {

db/mq/mynsq/producer.go

@@ -44,7 +44,7 @@ func create() (d interface{}, err error) {
 		err = errors.New("初始化 nsq producer 失败, err:" + err.Error())
 		return
 	}
-	// w.SetLogger(fmt.GetLogger(), gonsq.LogLevelDebug)
+	w.SetLogger(&interLog{}, gonsq.LogLevelDebug)
 	ret := &myProducer{producer: w}
 	d = interface{}(ret)
 	return d, err