aboutsummaryrefslogtreecommitdiff
path: root/weed/notification/log/log_queue.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/notification/log/log_queue.go')
-rw-r--r--weed/notification/log/log_queue.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/notification/log/log_queue.go b/weed/notification/log/log_queue.go
index 1ca4786a1..8f28265bc 100644
--- a/weed/notification/log/log_queue.go
+++ b/weed/notification/log/log_queue.go
@@ -1,7 +1,7 @@
package kafka
import (
- "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/util/log"
"github.com/chrislusf/seaweedfs/weed/notification"
"github.com/chrislusf/seaweedfs/weed/util"
"github.com/golang/protobuf/proto"
@@ -24,6 +24,6 @@ func (k *LogQueue) Initialize(configuration util.Configuration, prefix string) (
func (k *LogQueue) SendMessage(key string, message proto.Message) (err error) {
- glog.V(0).Infof("%v: %+v", key, message)
+ log.Infof("%v: %+v", key, message)
return nil
}