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
-		}
-	}
-
-}