aboutsummaryrefslogtreecommitdiff
path: root/weed/msgqueue/configuration.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-09-16 01:18:30 -0700
committerChris Lu <chris.lu@gmail.com>2018-09-16 01:18:30 -0700
commitd923ba2206a8238977e740f98f061242d61ed5e6 (patch)
treea2fcaf40d5f2398b2b8ad3c2a77a22579597cc1c /weed/msgqueue/configuration.go
parentbea4f6ca14615de23ba81a84cf61ba0f2a28b7f6 (diff)
downloadseaweedfs-d923ba2206a8238977e740f98f061242d61ed5e6.tar.xz
seaweedfs-d923ba2206a8238977e740f98f061242d61ed5e6.zip
renaming msgqueue to notification
Diffstat (limited to 'weed/msgqueue/configuration.go')
-rw-r--r--weed/msgqueue/configuration.go33
1 files changed, 0 insertions, 33 deletions
diff --git a/weed/msgqueue/configuration.go b/weed/msgqueue/configuration.go
deleted file mode 100644
index 769c11835..000000000
--- a/weed/msgqueue/configuration.go
+++ /dev/null
@@ -1,33 +0,0 @@
-package msgqueue
-
-import (
- "github.com/chrislusf/seaweedfs/weed/glog"
- "github.com/spf13/viper"
-)
-
-var (
- MessageQueues []MessageQueue
-
- Queue MessageQueue
-)
-
-func LoadConfiguration(config *viper.Viper) {
-
- if config == nil {
- return
- }
-
- for _, store := range MessageQueues {
- if config.GetBool(store.GetName() + ".enabled") {
- viperSub := config.Sub(store.GetName())
- if err := store.Initialize(viperSub); err != nil {
- glog.Fatalf("Failed to initialize store for %s: %+v",
- store.GetName(), err)
- }
- Queue = store
- glog.V(0).Infof("Configure message queue for %s", store.GetName())
- return
- }
- }
-
-}