1 files changed, 0 insertions, 29 deletions
diff --git a/weed/msgqueue/log/log_queue.go b/weed/msgqueue/log/log_queue.go
deleted file mode 100644
index d291d629c..000000000
--- a/weed/msgqueue/log/log_queue.go
+++ /dev/null
@@ -1,29 +0,0 @@
-package kafka
-
-import (
-	"github.com/chrislusf/seaweedfs/weed/glog"
-	"github.com/chrislusf/seaweedfs/weed/msgqueue"
-	"github.com/chrislusf/seaweedfs/weed/util"
-	"github.com/golang/protobuf/proto"
-)
-
-func init() {
-	msgqueue.MessageQueues = append(msgqueue.MessageQueues, &LogQueue{})
-}
-
-type LogQueue struct {
-}
-
-func (k *LogQueue) GetName() string {
-	return "log"
-}
-
-func (k *LogQueue) Initialize(configuration util.Configuration) (err error) {
-	return nil
-}
-
-func (k *LogQueue) SendMessage(key string, message proto.Message) (err error) {
-
-	glog.V(0).Infof("%v: %+v", key, message)
-	return nil
-}