diff --git a/log/mq/nsq.go b/log/mq/nsq.go
index 6acd2a6..57ee4ec 100644
--- a/log/mq/nsq.go
+++ b/log/mq/nsq.go
@@ -53,7 +53,7 @@ func (s *nsqLogger) Name() string {
 	return "app_log"
 }
 
-func NewNsqLogger(host string, topic string) log.Logger {
+func NewNsqLogger(host string, topic string) *nsqLogger {
 	client, err := nsq.NewProducer(host, nsq.NewConfig())
 	if err != nil {
 		panic(err)