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())