package rocketmq

import (
	"context"
	"fmt"
	"git.shuncheng.lu/bigthing/gocommon/pkg/internal/file"
	"testing"
	"time"
)

func Test_newLogger(t *testing.T) {
	SetLoggerInfoc(func(ctx context.Context, format string, v ...interface{}) {
		fmt.Printf(format, v...)
	})
	logger, err := newRocketLogger("info", file.NewDefaultRotateWriter("/data/log/go-common/rocket-mq.log"))
	if err != nil {
		t.Fatal(err)
	}

	logger.Info("hello world", map[string]interface{}{})

	time.Sleep(time.Second)
}