From bc03233364484653228066d9ea27b6e78ba640f6 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Sun, 16 Sep 2018 01:37:35 -0700 Subject: [PATCH] refactoring --- weed/notification/configuration.go | 10 ++++++++++ weed/notification/message_queue.go | 14 -------------- 2 files changed, 10 insertions(+), 14 deletions(-) delete mode 100644 weed/notification/message_queue.go diff --git a/weed/notification/configuration.go b/weed/notification/configuration.go index 6ac693ad8..96087987d 100644 --- a/weed/notification/configuration.go +++ b/weed/notification/configuration.go @@ -3,8 +3,18 @@ package notification import ( "github.com/chrislusf/seaweedfs/weed/glog" "github.com/spf13/viper" + "github.com/chrislusf/seaweedfs/weed/util" + "github.com/golang/protobuf/proto" ) +type MessageQueue interface { + // GetName gets the name to locate the configuration in filer.toml file + GetName() string + // Initialize initializes the file store + Initialize(configuration util.Configuration) error + SendMessage(key string, message proto.Message) error +} + var ( MessageQueues []MessageQueue diff --git a/weed/notification/message_queue.go b/weed/notification/message_queue.go deleted file mode 100644 index 18c4a8830..000000000 --- a/weed/notification/message_queue.go +++ /dev/null @@ -1,14 +0,0 @@ -package notification - -import ( - "github.com/chrislusf/seaweedfs/weed/util" - "github.com/golang/protobuf/proto" -) - -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 util.Configuration) error - SendMessage(key string, message proto.Message) error -}