From b800541fbea031d77814cc855d2a554a5dc36929 Mon Sep 17 00:00:00 2001 From: Praveen raj Mani Date: Fri, 24 Jul 2020 00:49:36 +0530 Subject: [PATCH] fix: a type in NSQ notification target environment key (#10118) fixes #10100 --- pkg/event/target/nsq.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/event/target/nsq.go b/pkg/event/target/nsq.go index 5a1be9914..198ec6243 100644 --- a/pkg/event/target/nsq.go +++ b/pkg/event/target/nsq.go @@ -40,7 +40,7 @@ const ( NSQQueueDir = "queue_dir" NSQQueueLimit = "queue_limit" - EnvNSQEnable = "MINIO_NOTIFY_NSQ" + EnvNSQEnable = "MINIO_NOTIFY_NSQ_ENABLE" EnvNSQAddress = "MINIO_NOTIFY_NSQ_NSQD_ADDRESS" EnvNSQTopic = "MINIO_NOTIFY_NSQ_TOPIC" EnvNSQTLS = "MINIO_NOTIFY_NSQ_TLS" @@ -210,7 +210,7 @@ func NewNSQTarget(id string, args NSQArgs, doneCh <-chan struct{}, loggerOnce fu store = NewQueueStore(queueDir, args.QueueLimit) if oErr := store.Open(); oErr != nil { target.loggerOnce(context.Background(), oErr, target.ID()) - return nil, oErr + return target, oErr } target.store = store } @@ -226,7 +226,7 @@ func NewNSQTarget(id string, args NSQArgs, doneCh <-chan struct{}, loggerOnce fu // To treat "connection refused" errors as errNotConnected. if target.store == nil || !(IsConnRefusedErr(err) || IsConnResetErr(err)) { target.loggerOnce(context.Background(), err, target.ID()) - return nil, err + return target, err } }