From f827ada811bb807a9cf9e3db702a01e6f8e4ae3b Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Sun, 19 Aug 2018 15:17:55 -0700 Subject: merge notification config with filer.toml --- weed/msgqueue/message_queue.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) (limited to 'weed/msgqueue/message_queue.go') diff --git a/weed/msgqueue/message_queue.go b/weed/msgqueue/message_queue.go index 6d57b9b3b..a14d9b480 100644 --- a/weed/msgqueue/message_queue.go +++ b/weed/msgqueue/message_queue.go @@ -1,11 +1,14 @@ package msgqueue -import "github.com/golang/protobuf/proto" +import ( + "github.com/golang/protobuf/proto" + "github.com/chrislusf/seaweedfs/weed/util" +) type MessageQueue interface { // GetName gets the name to locate the configuration in message_queue.toml file GetName() string // Initialize initializes the file store - Initialize(configuration Configuration) error + Initialize(configuration util.Configuration) error SendMessage(key string, message proto.Message) error } -- cgit v1.2.3