1 files changed, 33 insertions, 0 deletions
diff --git a/weed/notification/configuration.go b/weed/notification/configuration.go
new file mode 100644
index 000000000..6ac693ad8
--- /dev/null
+++ b/weed/notification/configuration.go
@@ -0,0 +1,33 @@
+package notification
+
+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
+		}
+	}
+
+}