resource/alicloud_amqp_instance: Fixed the product code for endpoint.

aliyun · Apr 18, 2024 · 6c98abf · 6c98abf
1 parent 9541e19
commit 6c98abf
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/alicloud/connectivity/client.go b/alicloud/connectivity/client.go
@@ -5375,7 +5375,7 @@ func (client *AliyunClient) NewDfsClient() (*rpc.Client, error) {
 	return conn, nil
 }
 func (client *AliyunClient) NewAmqpClient() (*rpc.Client, error) {
-	productCode := "amqp-open"
+	productCode := "onsproxy"
 	endpoint := ""
 	if v, ok := client.config.Endpoints.Load(productCode); !ok || v.(string) == "" {
 		if err := client.loadEndpoint(productCode); err != nil {

diff --git a/alicloud/resource_alicloud_amqp_instance.go b/alicloud/resource_alicloud_amqp_instance.go
@@ -179,7 +179,7 @@ func resourceAliCloudAmqpInstanceCreate(d *schema.ResourceData, meta interface{}
 	var request map[string]interface{}
 	var response map[string]interface{}
 	query := make(map[string]interface{})
-	conn, err := client.NewAmqpClient()
+	conn, err := client.NewOnsproxyClient()
 	if err != nil {
 		return WrapError(err)
 	}
@@ -395,7 +395,7 @@ func resourceAliCloudAmqpInstanceUpdate(d *schema.ResourceData, meta interface{}
 	}
 	update = false
 	action = "UpdateInstanceName"
-	conn, err = client.NewAmqpClient()
+	conn, err = client.NewOnsproxyClient()
 	if err != nil {
 		return WrapError(err)
 	}
@@ -431,7 +431,7 @@ func resourceAliCloudAmqpInstanceUpdate(d *schema.ResourceData, meta interface{}
 	}
 	update = false
 	action = "UpdateInstance"
-	conn, err = client.NewAmqpClient()
+	conn, err = client.NewOnsproxyClient()
 	if err != nil {
 		return WrapError(err)
 	}

diff --git a/alicloud/service_alicloud_amqp_v2.go b/alicloud/service_alicloud_amqp_v2.go
@@ -22,7 +22,7 @@ func (s *AmqpServiceV2) DescribeAmqpInstance(id string) (object map[string]inter
 	var response map[string]interface{}
 	var query map[string]interface{}
 	action := "GetInstance"
-	conn, err := client.NewAmqpClient()
+	conn, err := client.NewOnsproxyClient()
 	if err != nil {
 		return object, WrapError(err)
 	}