|
|
package kafka
import ( "github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/notification" "github.com/chrislusf/seaweedfs/weed/util" "github.com/golang/protobuf/proto" )
func init() { notification.MessageQueues = append(notification.MessageQueues, &LogQueue{}) }
type LogQueue struct { }
func (k *LogQueue) GetName() string { return "log" }
func (k *LogQueue) Initialize(configuration util.Configuration, prefix string) (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 }
|