[ISSUE #1136] should also set Credentials for nameserver in admin and pull consumer (#1137)
* should also set Credentials for nameserver in admin and pull consumer
* should set Credentials for nameserver
diff --git a/admin/admin.go b/admin/admin.go
index 62175af..a92a25c 100644
--- a/admin/admin.go
+++ b/admin/admin.go
@@ -102,6 +102,9 @@
if err != nil {
return nil, err
}
+ if !defaultOpts.Credentials.IsEmpty() {
+ namesrv.SetCredentials(defaultOpts.Credentials)
+ }
cli := internal.GetOrNewRocketMQClient(defaultOpts.ClientOptions, nil)
if cli == nil {
diff --git a/consumer/pull_consumer.go b/consumer/pull_consumer.go
index a64c163..c66ffb7 100644
--- a/consumer/pull_consumer.go
+++ b/consumer/pull_consumer.go
@@ -92,6 +92,9 @@
if err != nil {
return nil, errors.Wrap(err, "new Namesrv failed.")
}
+ if !defaultOpts.Credentials.IsEmpty() {
+ srvs.SetCredentials(defaultOpts.Credentials)
+ }
defaultOpts.Namesrv = srvs
dc := &defaultConsumer{
