refactoring

1 files changed, 14 insertions, 10 deletions

diff --git a/weed/notification/configuration.go b/weed/notification/configuration.go
index f34ccf305..7f8765cc3 100644
--- a/weed/notification/configuration.go
+++ b/weed/notification/configuration.go
@@ -27,16 +27,7 @@ func LoadConfiguration(config *viper.Viper) {
 		return
 	}
 
-	enabledQueue := ""
-	for _, queue := range MessageQueues {
-		if config.GetBool(queue.GetName() + ".enabled") {
-			if enabledQueue == "" {
-				enabledQueue = queue.GetName()
-			} else {
-				glog.Fatalf("Notification message queue is enabled for both %s and %s", enabledQueue, queue.GetName())
-			}
-		}
-	}
+	validateOneEnabledQueue(config)
 
 	for _, queue := range MessageQueues {
 		if config.GetBool(queue.GetName() + ".enabled") {
@@ -52,3 +43,16 @@ func LoadConfiguration(config *viper.Viper) {
 	}
 
 }
+
+func validateOneEnabledQueue(config *viper.Viper) {
+	enabledQueue := ""
+	for _, queue := range MessageQueues {
+		if config.GetBool(queue.GetName() + ".enabled") {
+			if enabledQueue == "" {
+				enabledQueue = queue.GetName()
+			} else {
+				glog.Fatalf("Notification message queue is enabled for both %s and %s", enabledQueue, queue.GetName())
+			}
+		}
+	}
+}