AzureSDKAutomation · openapi-sdkautomation · May 10, 2021
diff --git a/sdk/digitaltwins/azure-resourcemanager-digitaltwins/CHANGELOG.md b/sdk/digitaltwins/azure-resourcemanager-digitaltwins/CHANGELOG.md
@@ -1,7 +1,8 @@
 # Release History
 
-## 1.0.0-beta.2 (Unreleased)
+## 1.0.0-beta.1 (2021-05-10)
 
+- Azure Resource Manager AzureDigitalTwins client library for Java. This package contains Microsoft Azure SDK for AzureDigitalTwins Management SDK. Azure Digital Twins Client for managing DigitalTwinsInstance. Package tag package-2020-12. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
 
 ## 1.0.0-beta.1 (2021-03-02)
 

diff --git a/sdk/digitaltwins/azure-resourcemanager-digitaltwins/README.md b/sdk/digitaltwins/azure-resourcemanager-digitaltwins/README.md
@@ -32,7 +32,7 @@ Various documentation is available to help you get started
 <dependency>
     <groupId>com.azure.resourcemanager</groupId>
     <artifactId>azure-resourcemanager-digitaltwins</artifactId>
-    <version>1.0.0-beta.1</version>
+    <version>1.0.0-beta.2</version>
 </dependency>
 ```
 [//]: # ({x-version-update-end})

diff --git a/sdk/digitaltwins/azure-resourcemanager-digitaltwins/pom.xml b/sdk/digitaltwins/azure-resourcemanager-digitaltwins/pom.xml
@@ -13,7 +13,7 @@
     <packaging>jar</packaging>
 
     <name>Microsoft Azure SDK for AzureDigitalTwins Management</name>
-    <description>This package contains Microsoft Azure SDK for AzureDigitalTwins Management SDK. Azure Digital Twins Client for managing DigitalTwinsInstance. Package tag package-2020-12. For documentation on how to use this package, please see https://aka.ms/azsdk/java/mgmt</description>
+    <description>This package contains Microsoft Azure SDK for AzureDigitalTwins Management SDK. For documentation on how to use this package, please see https://aka.ms/azsdk/java/mgmt. Azure Digital Twins Client for managing DigitalTwinsInstance. Package tag package-2020-12.</description>
     <url>https://github.com/Azure/azure-sdk-for-java</url>
 
     <licenses>
@@ -51,30 +51,6 @@
             <artifactId>azure-core-management</artifactId>
             <version>1.2.2</version> <!-- {x-version-update;com.azure:azure-core-management;dependency} -->
         </dependency>
-        <dependency>
-            <groupId>com.azure</groupId>
-            <artifactId>azure-identity</artifactId>
-            <version>1.2.5</version> <!-- {x-version-update;com.azure:azure-identity;dependency} -->
-            <scope>test</scope>
-        </dependency>
-        <dependency>
-            <groupId>com.azure.resourcemanager</groupId>
-            <artifactId>azure-resourcemanager-resources</artifactId>
-            <version>2.4.0</version> <!-- {x-version-update;com.azure.resourcemanager:azure-resourcemanager-resources;dependency} -->
-            <scope>test</scope>
-        </dependency>
-        <dependency>
-            <groupId>com.azure</groupId>
-            <artifactId>azure-core-test</artifactId>
-            <version>1.6.2</version> <!-- {x-version-update;com.azure:azure-core-test;dependency} -->
-            <scope>test</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.slf4j</groupId>
-            <artifactId>slf4j-simple</artifactId>
-            <version>1.7.30</version> <!-- {x-version-update;org.slf4j:slf4j-simple;external_dependency} -->
-            <scope>test</scope>
-        </dependency>
     </dependencies>
     <build>
         <plugins>

diff --git a/...ltwins/src/main/java/com/azure/resourcemanager/digitaltwins/AzureDigitalTwinsManager.java b/...ltwins/src/main/java/com/azure/resourcemanager/digitaltwins/AzureDigitalTwinsManager.java
@@ -201,6 +201,7 @@ public AzureDigitalTwinsManager authenticate(TokenCredential credential, AzurePr
                 .add(
                     new BearerTokenAuthenticationPolicy(
                         credential, profile.getEnvironment().getManagementEndpoint() + "/.default"));
+            policies.addAll(this.policies);
             HttpPolicyProviders.addAfterRetryPolicies(policies);
             policies.add(new HttpLoggingPolicy(httpLogOptions));
             HttpPipeline httpPipeline =

diff --git a/...in/java/com/azure/resourcemanager/digitaltwins/fluent/models/GroupIdInformationInner.java b/...in/java/com/azure/resourcemanager/digitaltwins/fluent/models/GroupIdInformationInner.java
@@ -16,7 +16,7 @@ public final class GroupIdInformationInner {
     @JsonIgnore private final ClientLogger logger = new ClientLogger(GroupIdInformationInner.class);
 
     /*
-     * The properties for a group information object.
+     * The properties property.
      */
     @JsonProperty(value = "properties", required = true)
     private GroupIdInformationProperties properties;
@@ -40,7 +40,7 @@ public final class GroupIdInformationInner {
     private String type;
 
     /**
-     * Get the properties property: The properties for a group information object.
+     * Get the properties property: The properties property.
      *
      * @return the properties value.
      */
@@ -49,7 +49,7 @@ public GroupIdInformationProperties properties() {
     }
 
     /**
-     * Set the properties property: The properties for a group information object.
+     * Set the properties property: The properties property.
      *
      * @param properties the properties value to set.
      * @return the GroupIdInformationInner object itself.

diff --git a/.../com/azure/resourcemanager/digitaltwins/fluent/models/PrivateEndpointConnectionInner.java b/.../com/azure/resourcemanager/digitaltwins/fluent/models/PrivateEndpointConnectionInner.java
@@ -7,7 +7,7 @@
 import com.azure.core.annotation.Fluent;
 import com.azure.core.management.ProxyResource;
 import com.azure.core.util.logging.ClientLogger;
-import com.azure.resourcemanager.digitaltwins.models.ConnectionProperties;
+import com.azure.resourcemanager.digitaltwins.models.PrivateEndpointConnectionProperties;
 import com.fasterxml.jackson.annotation.JsonIgnore;
 import com.fasterxml.jackson.annotation.JsonProperty;
 
@@ -17,27 +17,27 @@ public final class PrivateEndpointConnectionInner extends ProxyResource {
     @JsonIgnore private final ClientLogger logger = new ClientLogger(PrivateEndpointConnectionInner.class);
 
     /*
-     * The properties of a private endpoint connection.
+     * The properties property.
      */
     @JsonProperty(value = "properties", required = true)
-    private ConnectionProperties properties;
+    private PrivateEndpointConnectionProperties properties;
 
     /**
-     * Get the properties property: The properties of a private endpoint connection.
+     * Get the properties property: The properties property.
      *
      * @return the properties value.
      */
-    public ConnectionProperties properties() {
+    public PrivateEndpointConnectionProperties properties() {
         return this.properties;
     }
 
     /**
-     * Set the properties property: The properties of a private endpoint connection.
+     * Set the properties property: The properties property.
      *
      * @param properties the properties value to set.
      * @return the PrivateEndpointConnectionInner object itself.
      */
-    public PrivateEndpointConnectionInner withProperties(ConnectionProperties properties) {
+    public PrivateEndpointConnectionInner withProperties(PrivateEndpointConnectionProperties properties) {
         this.properties = properties;
         return this;
     }

diff --git a/.../main/java/com/azure/resourcemanager/digitaltwins/implementation/CheckNameResultImpl.java b/.../main/java/com/azure/resourcemanager/digitaltwins/implementation/CheckNameResultImpl.java
@@ -4,17 +4,18 @@
 
 package com.azure.resourcemanager.digitaltwins.implementation;
 
-import com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager;
 import com.azure.resourcemanager.digitaltwins.fluent.models.CheckNameResultInner;
 import com.azure.resourcemanager.digitaltwins.models.CheckNameResult;
 import com.azure.resourcemanager.digitaltwins.models.Reason;
 
 public final class CheckNameResultImpl implements CheckNameResult {
     private CheckNameResultInner innerObject;
 
-    private final AzureDigitalTwinsManager serviceManager;
+    private final com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager serviceManager;
 
-    CheckNameResultImpl(CheckNameResultInner innerObject, AzureDigitalTwinsManager serviceManager) {
+    CheckNameResultImpl(
+        CheckNameResultInner innerObject,
+        com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager serviceManager) {
         this.innerObject = innerObject;
         this.serviceManager = serviceManager;
     }
@@ -35,7 +36,7 @@ public CheckNameResultInner innerModel() {
         return this.innerObject;
     }
 
-    private AzureDigitalTwinsManager manager() {
+    private com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager manager() {
         return this.serviceManager;
     }
 }
diff --git a/...in/java/com/azure/resourcemanager/digitaltwins/implementation/DigitalTwinsClientImpl.java b/...in/java/com/azure/resourcemanager/digitaltwins/implementation/DigitalTwinsClientImpl.java
@@ -240,7 +240,7 @@ private Mono<Response<DigitalTwinsDescriptionInner>> getByResourceGroupWithRespo
                             resourceName,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -399,7 +399,7 @@ private Mono<Response<Flux<ByteBuffer>>> createOrUpdateWithResponseAsync(
                             digitalTwinsCreate,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -707,7 +707,7 @@ private Mono<Response<Flux<ByteBuffer>>> updateWithResponseAsync(
                             digitalTwinsPatchDescription,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -988,7 +988,7 @@ private Mono<Response<Flux<ByteBuffer>>> deleteWithResponseAsync(String resource
                             resourceName,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1226,7 +1226,7 @@ private Mono<PagedResponse<DigitalTwinsDescriptionInner>> listSinglePageAsync()
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1374,7 +1374,7 @@ private Mono<PagedResponse<DigitalTwinsDescriptionInner>> listByResourceGroupSin
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1540,7 +1540,7 @@ private Mono<Response<CheckNameResultInner>> checkNameAvailabilityWithResponseAs
                             digitalTwinsInstanceCheckName,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1685,7 +1685,7 @@ private Mono<PagedResponse<DigitalTwinsDescriptionInner>> listNextSinglePageAsyn
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1758,7 +1758,7 @@ private Mono<PagedResponse<DigitalTwinsDescriptionInner>> listByResourceGroupNex
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**

diff --git a/...va/com/azure/resourcemanager/digitaltwins/implementation/DigitalTwinsDescriptionImpl.java b/...va/com/azure/resourcemanager/digitaltwins/implementation/DigitalTwinsDescriptionImpl.java
@@ -6,7 +6,6 @@
 
 import com.azure.core.management.Region;
 import com.azure.core.util.Context;
-import com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager;
 import com.azure.resourcemanager.digitaltwins.fluent.models.DigitalTwinsDescriptionInner;
 import com.azure.resourcemanager.digitaltwins.fluent.models.PrivateEndpointConnectionInner;
 import com.azure.resourcemanager.digitaltwins.models.DigitalTwinsDescription;
@@ -26,7 +25,7 @@ public final class DigitalTwinsDescriptionImpl
     implements DigitalTwinsDescription, DigitalTwinsDescription.Definition, DigitalTwinsDescription.Update {
     private DigitalTwinsDescriptionInner innerObject;
 
-    private final AzureDigitalTwinsManager serviceManager;
+    private final com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager serviceManager;
 
     public String id() {
         return this.innerModel().id();
@@ -103,7 +102,7 @@ public DigitalTwinsDescriptionInner innerModel() {
         return this.innerObject;
     }
 
-    private AzureDigitalTwinsManager manager() {
+    private com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager manager() {
         return this.serviceManager;
     }
 
@@ -136,7 +135,8 @@ public DigitalTwinsDescription create(Context context) {
         return this;
     }
 
-    DigitalTwinsDescriptionImpl(String name, AzureDigitalTwinsManager serviceManager) {
+    DigitalTwinsDescriptionImpl(
+        String name, com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager serviceManager) {
         this.innerObject = new DigitalTwinsDescriptionInner();
         this.serviceManager = serviceManager;
         this.resourceName = name;
@@ -165,7 +165,9 @@ public DigitalTwinsDescription apply(Context context) {
         return this;
     }
 
-    DigitalTwinsDescriptionImpl(DigitalTwinsDescriptionInner innerObject, AzureDigitalTwinsManager serviceManager) {
+    DigitalTwinsDescriptionImpl(
+        DigitalTwinsDescriptionInner innerObject,
+        com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager serviceManager) {
         this.innerObject = innerObject;
         this.serviceManager = serviceManager;
         this.resourceGroupName = Utils.getValueFromIdByName(innerObject.id(), "resourceGroups");

diff --git a/...m/azure/resourcemanager/digitaltwins/implementation/DigitalTwinsEndpointResourceImpl.java b/...m/azure/resourcemanager/digitaltwins/implementation/DigitalTwinsEndpointResourceImpl.java
@@ -5,7 +5,6 @@
 package com.azure.resourcemanager.digitaltwins.implementation;
 
 import com.azure.core.util.Context;
-import com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager;
 import com.azure.resourcemanager.digitaltwins.fluent.models.DigitalTwinsEndpointResourceInner;
 import com.azure.resourcemanager.digitaltwins.models.DigitalTwinsEndpointResource;
 import com.azure.resourcemanager.digitaltwins.models.DigitalTwinsEndpointResourceProperties;
@@ -16,7 +15,7 @@ public final class DigitalTwinsEndpointResourceImpl
         DigitalTwinsEndpointResource.Update {
     private DigitalTwinsEndpointResourceInner innerObject;
 
-    private final AzureDigitalTwinsManager serviceManager;
+    private final com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager serviceManager;
 
     public String id() {
         return this.innerModel().id();
@@ -38,7 +37,7 @@ public DigitalTwinsEndpointResourceInner innerModel() {
         return this.innerObject;
     }
 
-    private AzureDigitalTwinsManager manager() {
+    private com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager manager() {
         return this.serviceManager;
     }
 
@@ -73,7 +72,8 @@ public DigitalTwinsEndpointResource create(Context context) {
         return this;
     }
 
-    DigitalTwinsEndpointResourceImpl(String name, AzureDigitalTwinsManager serviceManager) {
+    DigitalTwinsEndpointResourceImpl(
+        String name, com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager serviceManager) {
         this.innerObject = new DigitalTwinsEndpointResourceInner();
         this.serviceManager = serviceManager;
         this.endpointName = name;
@@ -102,7 +102,8 @@ public DigitalTwinsEndpointResource apply(Context context) {
     }
 
     DigitalTwinsEndpointResourceImpl(
-        DigitalTwinsEndpointResourceInner innerObject, AzureDigitalTwinsManager serviceManager) {
+        DigitalTwinsEndpointResourceInner innerObject,
+        com.azure.resourcemanager.digitaltwins.AzureDigitalTwinsManager serviceManager) {
         this.innerObject = innerObject;
         this.serviceManager = serviceManager;
         this.resourceGroupName = Utils.getValueFromIdByName(innerObject.id(), "resourceGroups");

diff --git a/...om/azure/resourcemanager/digitaltwins/implementation/DigitalTwinsEndpointsClientImpl.java b/...om/azure/resourcemanager/digitaltwins/implementation/DigitalTwinsEndpointsClientImpl.java
@@ -197,7 +197,7 @@ private Mono<PagedResponse<DigitalTwinsEndpointResourceInner>> listSinglePageAsy
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -372,7 +372,7 @@ private Mono<Response<DigitalTwinsEndpointResourceInner>> getWithResponseAsync(
                             endpointName,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -546,7 +546,7 @@ private Mono<Response<Flux<ByteBuffer>>> createOrUpdateWithResponseAsync(
                             endpointDescription,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -868,7 +868,7 @@ private Mono<Response<Flux<ByteBuffer>>> deleteWithResponseAsync(
                             endpointName,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1116,7 +1116,7 @@ private Mono<PagedResponse<DigitalTwinsEndpointResourceInner>> listNextSinglePag
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**