fix(deps): Update the Java code generator (gapic-generator-java) to 2…

….32.0 (#1573)

* fix(deps): Update the Java code generator (gapic-generator-java) to 2.32.0

PiperOrigin-RevId: 599914188

Source-Link: googleapis/googleapis@17e6661

Source-Link: googleapis/googleapis-gen@d86ba5b
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZDg2YmE1YmU1MzdlNDg5NDM1MTA1Y2E4NTU2NmNjNDEwMzMwMWFiYSJ9

* 🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

---------

Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/CursorServiceClient.java

@@ -71,53 +71,53 @@
  * as threads. In the example above, try-with-resources is used, which automatically calls close().
  *
  * <table>
- *   <caption>Methods</caption>
+ *    <caption>Methods</caption>
  *    <tr>
  *      <th>Method</th>
  *      <th>Description</th>
  *      <th>Method Variants</th>
  *    </tr>
  *    <tr>
- *      <td>StreamingCommitCursor</td>
+ *      <td><p> StreamingCommitCursor</td>
  *      <td><p> Establishes a stream with the server for managing committed cursors.</td>
  *      <td>
  *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
  *      <ul>
- *           <li>streamingCommitCursorCallable()
+ *           <li><p> streamingCommitCursorCallable()
  *      </ul>
  *       </td>
  *    </tr>
  *    <tr>
- *      <td>CommitCursor</td>
+ *      <td><p> CommitCursor</td>
  *      <td><p> Updates the committed cursor.</td>
  *      <td>
  *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
  *      <ul>
- *           <li>commitCursor(CommitCursorRequest request)
+ *           <li><p> commitCursor(CommitCursorRequest request)
  *      </ul>
  *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
  *      <ul>
- *           <li>commitCursorCallable()
+ *           <li><p> commitCursorCallable()
  *      </ul>
  *       </td>
  *    </tr>
  *    <tr>
- *      <td>ListPartitionCursors</td>
+ *      <td><p> ListPartitionCursors</td>
  *      <td><p> Returns all committed cursor information for a subscription.</td>
  *      <td>
  *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
  *      <ul>
- *           <li>listPartitionCursors(ListPartitionCursorsRequest request)
+ *           <li><p> listPartitionCursors(ListPartitionCursorsRequest request)
  *      </ul>
  *      <p>"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.</p>
  *      <ul>
- *           <li>listPartitionCursors(SubscriptionName parent)
- *           <li>listPartitionCursors(String parent)
+ *           <li><p> listPartitionCursors(SubscriptionName parent)
+ *           <li><p> listPartitionCursors(String parent)
  *      </ul>
  *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
  *      <ul>
- *           <li>listPartitionCursorsPagedCallable()
- *           <li>listPartitionCursorsCallable()
+ *           <li><p> listPartitionCursorsPagedCallable()
+ *           <li><p> listPartitionCursorsCallable()
  *      </ul>
  *       </td>
  *    </tr>

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/PartitionAssignmentServiceClient.java

@@ -57,20 +57,20 @@
  * calls close().
  *
  * <table>
- *   <caption>Methods</caption>
+ *    <caption>Methods</caption>
  *    <tr>
  *      <th>Method</th>
  *      <th>Description</th>
  *      <th>Method Variants</th>
  *    </tr>
  *    <tr>
- *      <td>AssignPartitions</td>
+ *      <td><p> AssignPartitions</td>
  *      <td><p> Assign partitions for this client to handle for the specified subscription.
  * <p>  The client must send an InitialPartitionAssignmentRequest first. The server will then send at most one unacknowledged PartitionAssignment outstanding on the stream at a time. The client should send a PartitionAssignmentAck after updating the partitions it is connected to to reflect the new assignment.</td>
  *      <td>
  *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
  *      <ul>
- *           <li>assignPartitionsCallable()
+ *           <li><p> assignPartitionsCallable()
  *      </ul>
  *       </td>
  *    </tr>

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/PublisherServiceClient.java

@@ -58,19 +58,19 @@
  * close().
  *
  * <table>
- *   <caption>Methods</caption>
+ *    <caption>Methods</caption>
  *    <tr>
  *      <th>Method</th>
  *      <th>Description</th>
  *      <th>Method Variants</th>
  *    </tr>
  *    <tr>
- *      <td>Publish</td>
+ *      <td><p> Publish</td>
  *      <td><p> Establishes a stream with the server for publishing messages. Once the stream is initialized, the client publishes messages by sending publish requests on the stream. The server responds with a PublishResponse for each PublishRequest sent by the client, in the same order that the requests were sent. Note that multiple PublishRequests can be in flight simultaneously, but they will be processed by the server in the order that they are sent by the client on a given stream.</td>
  *      <td>
  *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
  *      <ul>
- *           <li>publishCallable()
+ *           <li><p> publishCallable()
  *      </ul>
  *       </td>
  *    </tr>

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/SubscriberServiceClient.java

@@ -56,19 +56,19 @@
  * close().
  *
  * <table>
- *   <caption>Methods</caption>
+ *    <caption>Methods</caption>
  *    <tr>
  *      <th>Method</th>
  *      <th>Description</th>
  *      <th>Method Variants</th>
  *    </tr>
  *    <tr>
- *      <td>Subscribe</td>
+ *      <td><p> Subscribe</td>
  *      <td><p> Establishes a stream with the server for receiving messages.</td>
  *      <td>
  *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
  *      <ul>
- *           <li>subscribeCallable()
+ *           <li><p> subscribeCallable()
  *      </ul>
  *       </td>
  *    </tr>

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/TopicStatsServiceClient.java

@@ -60,51 +60,51 @@
  * close().
  *
  * <table>
- *   <caption>Methods</caption>
+ *    <caption>Methods</caption>
  *    <tr>
  *      <th>Method</th>
  *      <th>Description</th>
  *      <th>Method Variants</th>
  *    </tr>
  *    <tr>
- *      <td>ComputeMessageStats</td>
+ *      <td><p> ComputeMessageStats</td>
  *      <td><p> Compute statistics about a range of messages in a given topic and partition.</td>
  *      <td>
  *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
  *      <ul>
- *           <li>computeMessageStats(ComputeMessageStatsRequest request)
+ *           <li><p> computeMessageStats(ComputeMessageStatsRequest request)
  *      </ul>
  *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
  *      <ul>
- *           <li>computeMessageStatsCallable()
+ *           <li><p> computeMessageStatsCallable()
  *      </ul>
  *       </td>
  *    </tr>
  *    <tr>
- *      <td>ComputeHeadCursor</td>
+ *      <td><p> ComputeHeadCursor</td>
  *      <td><p> Compute the head cursor for the partition. The head cursor's offset is guaranteed to be less than or equal to all messages which have not yet been acknowledged as published, and greater than the offset of any message whose publish has already been acknowledged. It is zero if there have never been messages in the partition.</td>
  *      <td>
  *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
  *      <ul>
- *           <li>computeHeadCursor(ComputeHeadCursorRequest request)
+ *           <li><p> computeHeadCursor(ComputeHeadCursorRequest request)
  *      </ul>
  *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
  *      <ul>
- *           <li>computeHeadCursorCallable()
+ *           <li><p> computeHeadCursorCallable()
  *      </ul>
  *       </td>
  *    </tr>
  *    <tr>
- *      <td>ComputeTimeCursor</td>
+ *      <td><p> ComputeTimeCursor</td>
  *      <td><p> Compute the corresponding cursor for a publish or event time in a topic partition.</td>
  *      <td>
  *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
  *      <ul>
- *           <li>computeTimeCursor(ComputeTimeCursorRequest request)
+ *           <li><p> computeTimeCursor(ComputeTimeCursorRequest request)
  *      </ul>
  *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
  *      <ul>
- *           <li>computeTimeCursorCallable()
+ *           <li><p> computeTimeCursorCallable()
  *      </ul>
  *       </td>
  *    </tr>

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/stub/AdminServiceStubSettings.java

@@ -599,6 +599,15 @@ public AdminServiceStub createStub() throws IOException {
             "Transport not supported: %s", getTransportChannelProvider().getTransportName()));
   }
 
+  /** Returns the endpoint set by the user or the the service's default endpoint. */
+  @Override
+  public String getEndpoint() {
+    if (super.getEndpoint() != null) {
+      return super.getEndpoint();
+    }
+    return getDefaultEndpoint();
+  }
+
   /** Returns the default service name. */
   @Override
   public String getServiceName() {
@@ -884,7 +893,6 @@ private static Builder createDefault() {
       builder.setTransportChannelProvider(defaultTransportChannelProvider());
       builder.setCredentialsProvider(defaultCredentialsProviderBuilder().build());
       builder.setInternalHeaderProvider(defaultApiClientHeaderProviderBuilder().build());
-      builder.setEndpoint(getDefaultEndpoint());
       builder.setMtlsEndpoint(getDefaultMtlsEndpoint());
       builder.setSwitchToMtlsEndpointAllowed(true);
 
@@ -1154,6 +1162,15 @@ public UnaryCallSettings.Builder<DeleteReservationRequest, Empty> deleteReservat
       return listReservationTopicsSettings;
     }
 
+    /** Returns the endpoint set by the user or the the service's default endpoint. */
+    @Override
+    public String getEndpoint() {
+      if (super.getEndpoint() != null) {
+        return super.getEndpoint();
+      }
+      return getDefaultEndpoint();
+    }
+
     @Override
     public AdminServiceStubSettings build() throws IOException {
       return new AdminServiceStubSettings(this);

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/stub/CursorServiceStubSettings.java

@@ -205,6 +205,15 @@ public CursorServiceStub createStub() throws IOException {
             "Transport not supported: %s", getTransportChannelProvider().getTransportName()));
   }
 
+  /** Returns the endpoint set by the user or the the service's default endpoint. */
+  @Override
+  public String getEndpoint() {
+    if (super.getEndpoint() != null) {
+      return super.getEndpoint();
+    }
+    return getDefaultEndpoint();
+  }
+
   /** Returns the default service name. */
   @Override
   public String getServiceName() {
@@ -369,7 +378,6 @@ private static Builder createDefault() {
       builder.setTransportChannelProvider(defaultTransportChannelProvider());
       builder.setCredentialsProvider(defaultCredentialsProviderBuilder().build());
       builder.setInternalHeaderProvider(defaultApiClientHeaderProviderBuilder().build());
-      builder.setEndpoint(getDefaultEndpoint());
       builder.setMtlsEndpoint(getDefaultMtlsEndpoint());
       builder.setSwitchToMtlsEndpointAllowed(true);
 
@@ -427,6 +435,15 @@ public Builder applyToAllUnaryMethods(
       return listPartitionCursorsSettings;
     }
 
+    /** Returns the endpoint set by the user or the the service's default endpoint. */
+    @Override
+    public String getEndpoint() {
+      if (super.getEndpoint() != null) {
+        return super.getEndpoint();
+      }
+      return getDefaultEndpoint();
+    }
+
     @Override
     public CursorServiceStubSettings build() throws IOException {
       return new CursorServiceStubSettings(this);

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/stub/PartitionAssignmentServiceStubSettings.java

@@ -107,6 +107,15 @@ public PartitionAssignmentServiceStub createStub() throws IOException {
             "Transport not supported: %s", getTransportChannelProvider().getTransportName()));
   }
 
+  /** Returns the endpoint set by the user or the the service's default endpoint. */
+  @Override
+  public String getEndpoint() {
+    if (super.getEndpoint() != null) {
+      return super.getEndpoint();
+    }
+    return getDefaultEndpoint();
+  }
+
   /** Returns the default service name. */
   @Override
   public String getServiceName() {
@@ -233,7 +242,6 @@ private static Builder createDefault() {
       builder.setTransportChannelProvider(defaultTransportChannelProvider());
       builder.setCredentialsProvider(defaultCredentialsProviderBuilder().build());
       builder.setInternalHeaderProvider(defaultApiClientHeaderProviderBuilder().build());
-      builder.setEndpoint(getDefaultEndpoint());
       builder.setMtlsEndpoint(getDefaultMtlsEndpoint());
       builder.setSwitchToMtlsEndpointAllowed(true);
 
@@ -265,6 +273,15 @@ public Builder applyToAllUnaryMethods(
       return assignPartitionsSettings;
     }
 
+    /** Returns the endpoint set by the user or the the service's default endpoint. */
+    @Override
+    public String getEndpoint() {
+      if (super.getEndpoint() != null) {
+        return super.getEndpoint();
+      }
+      return getDefaultEndpoint();
+    }
+
     @Override
     public PartitionAssignmentServiceStubSettings build() throws IOException {
       return new PartitionAssignmentServiceStubSettings(this);

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/stub/PublisherServiceStubSettings.java

@@ -103,6 +103,15 @@ public PublisherServiceStub createStub() throws IOException {
             "Transport not supported: %s", getTransportChannelProvider().getTransportName()));
   }
 
+  /** Returns the endpoint set by the user or the the service's default endpoint. */
+  @Override
+  public String getEndpoint() {
+    if (super.getEndpoint() != null) {
+      return super.getEndpoint();
+    }
+    return getDefaultEndpoint();
+  }
+
   /** Returns the default service name. */
   @Override
   public String getServiceName() {
@@ -227,7 +236,6 @@ private static Builder createDefault() {
       builder.setTransportChannelProvider(defaultTransportChannelProvider());
       builder.setCredentialsProvider(defaultCredentialsProviderBuilder().build());
       builder.setInternalHeaderProvider(defaultApiClientHeaderProviderBuilder().build());
-      builder.setEndpoint(getDefaultEndpoint());
       builder.setMtlsEndpoint(getDefaultMtlsEndpoint());
       builder.setSwitchToMtlsEndpointAllowed(true);
 
@@ -258,6 +266,15 @@ public StreamingCallSettings.Builder<PublishRequest, PublishResponse> publishSet
       return publishSettings;
     }
 
+    /** Returns the endpoint set by the user or the the service's default endpoint. */
+    @Override
+    public String getEndpoint() {
+      if (super.getEndpoint() != null) {
+        return super.getEndpoint();
+      }
+      return getDefaultEndpoint();
+    }
+
     @Override
     public PublisherServiceStubSettings build() throws IOException {
       return new PublisherServiceStubSettings(this);

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/stub/SubscriberServiceStubSettings.java

@@ -104,6 +104,15 @@ public SubscriberServiceStub createStub() throws IOException {
             "Transport not supported: %s", getTransportChannelProvider().getTransportName()));
   }
 
+  /** Returns the endpoint set by the user or the the service's default endpoint. */
+  @Override
+  public String getEndpoint() {
+    if (super.getEndpoint() != null) {
+      return super.getEndpoint();
+    }
+    return getDefaultEndpoint();
+  }
+
   /** Returns the default service name. */
   @Override
   public String getServiceName() {
@@ -229,7 +238,6 @@ private static Builder createDefault() {
       builder.setTransportChannelProvider(defaultTransportChannelProvider());
       builder.setCredentialsProvider(defaultCredentialsProviderBuilder().build());
       builder.setInternalHeaderProvider(defaultApiClientHeaderProviderBuilder().build());
-      builder.setEndpoint(getDefaultEndpoint());
       builder.setMtlsEndpoint(getDefaultMtlsEndpoint());
       builder.setSwitchToMtlsEndpointAllowed(true);
 
@@ -260,6 +268,15 @@ public StreamingCallSettings.Builder<SubscribeRequest, SubscribeResponse> subscr
       return subscribeSettings;
     }
 
+    /** Returns the endpoint set by the user or the the service's default endpoint. */
+    @Override
+    public String getEndpoint() {
+      if (super.getEndpoint() != null) {
+        return super.getEndpoint();
+      }
+      return getDefaultEndpoint();
+    }
+
     @Override
     public SubscriberServiceStubSettings build() throws IOException {
       return new SubscriberServiceStubSettings(this);