aboutsummaryrefslogtreecommitdiff
path: root/weed/msgqueue
diff options
context:
space:
mode:
Diffstat (limited to 'weed/msgqueue')
-rw-r--r--weed/msgqueue/configuration.go4
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/msgqueue/configuration.go b/weed/msgqueue/configuration.go
index d053f892f..769c11835 100644
--- a/weed/msgqueue/configuration.go
+++ b/weed/msgqueue/configuration.go
@@ -13,6 +13,10 @@ var (
func LoadConfiguration(config *viper.Viper) {
+ if config == nil {
+ return
+ }
+
for _, store := range MessageQueues {
if config.GetBool(store.GetName() + ".enabled") {
viperSub := config.Sub(store.GetName())