listQueue
*
* {@code
* try (CloudTasksClient cloudTasksClient = CloudTasksClient.create()) {
+ * ListQueuesRequest request =
+ * ListQueuesRequest.newBuilder()
+ * .setParent(QueueName.of("[PROJECT]", "[LOCATION]", "[QUEUE]").toString())
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
* while (true) {
* ListQueuesResponse response = cloudTasksClient.listQueuesCallable().call(request);
* for (Queue element : response.getResponsesList()) {
@@ -1665,6 +1672,12 @@ public final UnaryCallable listTasksPa
*
* {@code
* try (CloudTasksClient cloudTasksClient = CloudTasksClient.create()) {
+ * ListTasksRequest request =
+ * ListTasksRequest.newBuilder()
+ * .setParent(TaskName.of("[PROJECT]", "[LOCATION]", "[QUEUE]", "[TASK]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
* while (true) {
* ListTasksResponse response = cloudTasksClient.listTasksCallable().call(request);
* for (Task element : response.getResponsesList()) {
diff --git a/google-cloud-tasks/src/main/java/com/google/cloud/tasks/v2beta2/CloudTasksClient.java b/google-cloud-tasks/src/main/java/com/google/cloud/tasks/v2beta2/CloudTasksClient.java
index 0cc31811..e23cf997 100644
--- a/google-cloud-tasks/src/main/java/com/google/cloud/tasks/v2beta2/CloudTasksClient.java
+++ b/google-cloud-tasks/src/main/java/com/google/cloud/tasks/v2beta2/CloudTasksClient.java
@@ -281,6 +281,14 @@ public final UnaryCallable listQueue
*
* {@code
* try (CloudTasksClient cloudTasksClient = CloudTasksClient.create()) {
+ * ListQueuesRequest request =
+ * ListQueuesRequest.newBuilder()
+ * .setParent(QueueName.of("[PROJECT]", "[LOCATION]", "[QUEUE]").toString())
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setReadMask(FieldMask.newBuilder().build())
+ * .build();
* while (true) {
* ListQueuesResponse response = cloudTasksClient.listQueuesCallable().call(request);
* for (Queue element : response.getResponsesList()) {
@@ -1676,6 +1684,12 @@ public final UnaryCallable listTasksPa
*
* {@code
* try (CloudTasksClient cloudTasksClient = CloudTasksClient.create()) {
+ * ListTasksRequest request =
+ * ListTasksRequest.newBuilder()
+ * .setParent(TaskName.of("[PROJECT]", "[LOCATION]", "[QUEUE]", "[TASK]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
* while (true) {
* ListTasksResponse response = cloudTasksClient.listTasksCallable().call(request);
* for (Task element : response.getResponsesList()) {
diff --git a/google-cloud-tasks/src/main/java/com/google/cloud/tasks/v2beta3/CloudTasksClient.java b/google-cloud-tasks/src/main/java/com/google/cloud/tasks/v2beta3/CloudTasksClient.java
index 00325a4f..2406492f 100644
--- a/google-cloud-tasks/src/main/java/com/google/cloud/tasks/v2beta3/CloudTasksClient.java
+++ b/google-cloud-tasks/src/main/java/com/google/cloud/tasks/v2beta3/CloudTasksClient.java
@@ -279,6 +279,14 @@ public final UnaryCallable listQueue
*
* {@code
* try (CloudTasksClient cloudTasksClient = CloudTasksClient.create()) {
+ * ListQueuesRequest request =
+ * ListQueuesRequest.newBuilder()
+ * .setParent(QueueName.of("[PROJECT]", "[LOCATION]", "[QUEUE]").toString())
+ * .setFilter("filter-1274492040")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setReadMask(FieldMask.newBuilder().build())
+ * .build();
* while (true) {
* ListQueuesResponse response = cloudTasksClient.listQueuesCallable().call(request);
* for (Queue element : response.getResponsesList()) {
@@ -1674,6 +1682,12 @@ public final UnaryCallable listTasksPa
*
* {@code
* try (CloudTasksClient cloudTasksClient = CloudTasksClient.create()) {
+ * ListTasksRequest request =
+ * ListTasksRequest.newBuilder()
+ * .setParent(TaskName.of("[PROJECT]", "[LOCATION]", "[QUEUE]", "[TASK]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
* while (true) {
* ListTasksResponse response = cloudTasksClient.listTasksCallable().call(request);
* for (Task element : response.getResponsesList()) {
diff --git a/google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2/MockCloudTasksImpl.java b/google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2/MockCloudTasksImpl.java
index 4df154c6..3e5a4ac0 100644
--- a/google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2/MockCloudTasksImpl.java
+++ b/google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2/MockCloudTasksImpl.java
@@ -67,7 +67,7 @@ public void reset() {
@Override
public void listQueues(
ListQueuesRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListQueuesResponse) {
requests.add(request);
responseObserver.onNext(((ListQueuesResponse) response));
@@ -79,7 +79,7 @@ public void listQueues(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListQueues, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListQueuesResponse.class.getName(),
Exception.class.getName())));
}
@@ -88,7 +88,7 @@ public void listQueues(
@Override
public void getQueue(
GetQueueRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2.Queue) response));
@@ -100,7 +100,7 @@ public void getQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2.Queue.class.getName(),
Exception.class.getName())));
}
@@ -110,7 +110,7 @@ public void getQueue(
public void createQueue(
CreateQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2.Queue) response));
@@ -122,7 +122,7 @@ public void createQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2.Queue.class.getName(),
Exception.class.getName())));
}
@@ -132,7 +132,7 @@ public void createQueue(
public void updateQueue(
UpdateQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2.Queue) response));
@@ -144,7 +144,7 @@ public void updateQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method UpdateQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2.Queue.class.getName(),
Exception.class.getName())));
}
@@ -152,7 +152,7 @@ public void updateQueue(
@Override
public void deleteQueue(DeleteQueueRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -164,7 +164,7 @@ public void deleteQueue(DeleteQueueRequest request, StreamObserver respon
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -173,7 +173,7 @@ public void deleteQueue(DeleteQueueRequest request, StreamObserver respon
@Override
public void purgeQueue(
PurgeQueueRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2.Queue) response));
@@ -185,7 +185,7 @@ public void purgeQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method PurgeQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2.Queue.class.getName(),
Exception.class.getName())));
}
@@ -194,7 +194,7 @@ public void purgeQueue(
@Override
public void pauseQueue(
PauseQueueRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2.Queue) response));
@@ -206,7 +206,7 @@ public void pauseQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method PauseQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2.Queue.class.getName(),
Exception.class.getName())));
}
@@ -216,7 +216,7 @@ public void pauseQueue(
public void resumeQueue(
ResumeQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2.Queue) response));
@@ -228,7 +228,7 @@ public void resumeQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ResumeQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2.Queue.class.getName(),
Exception.class.getName())));
}
@@ -236,7 +236,7 @@ public void resumeQueue(
@Override
public void getIamPolicy(GetIamPolicyRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
@@ -248,7 +248,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetIamPolicy, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Policy.class.getName(),
Exception.class.getName())));
}
@@ -256,7 +256,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver res
@Override
public void setIamPolicy(SetIamPolicyRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
@@ -268,7 +268,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method SetIamPolicy, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Policy.class.getName(),
Exception.class.getName())));
}
@@ -278,7 +278,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver res
public void testIamPermissions(
TestIamPermissionsRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof TestIamPermissionsResponse) {
requests.add(request);
responseObserver.onNext(((TestIamPermissionsResponse) response));
@@ -290,7 +290,7 @@ public void testIamPermissions(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method TestIamPermissions, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
TestIamPermissionsResponse.class.getName(),
Exception.class.getName())));
}
@@ -299,7 +299,7 @@ public void testIamPermissions(
@Override
public void listTasks(
ListTasksRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListTasksResponse) {
requests.add(request);
responseObserver.onNext(((ListTasksResponse) response));
@@ -311,7 +311,7 @@ public void listTasks(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListTasks, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListTasksResponse.class.getName(),
Exception.class.getName())));
}
@@ -319,7 +319,7 @@ public void listTasks(
@Override
public void getTask(GetTaskRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Task) {
requests.add(request);
responseObserver.onNext(((Task) response));
@@ -331,13 +331,15 @@ public void getTask(GetTaskRequest request, StreamObserver responseObserve
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetTask, expected %s or %s",
- response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
+ response == null ? "null" : response.getClass().getName(),
+ Task.class.getName(),
+ Exception.class.getName())));
}
}
@Override
public void createTask(CreateTaskRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Task) {
requests.add(request);
responseObserver.onNext(((Task) response));
@@ -349,13 +351,15 @@ public void createTask(CreateTaskRequest request, StreamObserver responseO
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateTask, expected %s or %s",
- response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
+ response == null ? "null" : response.getClass().getName(),
+ Task.class.getName(),
+ Exception.class.getName())));
}
}
@Override
public void deleteTask(DeleteTaskRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -367,7 +371,7 @@ public void deleteTask(DeleteTaskRequest request, StreamObserver response
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteTask, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -375,7 +379,7 @@ public void deleteTask(DeleteTaskRequest request, StreamObserver response
@Override
public void runTask(RunTaskRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Task) {
requests.add(request);
responseObserver.onNext(((Task) response));
@@ -387,7 +391,9 @@ public void runTask(RunTaskRequest request, StreamObserver responseObserve
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method RunTask, expected %s or %s",
- response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
+ response == null ? "null" : response.getClass().getName(),
+ Task.class.getName(),
+ Exception.class.getName())));
}
}
}
diff --git a/google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2beta2/MockCloudTasksImpl.java b/google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2beta2/MockCloudTasksImpl.java
index cd24f793..0ed40abb 100644
--- a/google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2beta2/MockCloudTasksImpl.java
+++ b/google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2beta2/MockCloudTasksImpl.java
@@ -67,7 +67,7 @@ public void reset() {
@Override
public void listQueues(
ListQueuesRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListQueuesResponse) {
requests.add(request);
responseObserver.onNext(((ListQueuesResponse) response));
@@ -79,7 +79,7 @@ public void listQueues(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListQueues, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListQueuesResponse.class.getName(),
Exception.class.getName())));
}
@@ -89,7 +89,7 @@ public void listQueues(
public void getQueue(
GetQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2beta2.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2beta2.Queue) response));
@@ -101,7 +101,7 @@ public void getQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2beta2.Queue.class.getName(),
Exception.class.getName())));
}
@@ -111,7 +111,7 @@ public void getQueue(
public void createQueue(
CreateQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2beta2.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2beta2.Queue) response));
@@ -123,7 +123,7 @@ public void createQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2beta2.Queue.class.getName(),
Exception.class.getName())));
}
@@ -133,7 +133,7 @@ public void createQueue(
public void updateQueue(
UpdateQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2beta2.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2beta2.Queue) response));
@@ -145,7 +145,7 @@ public void updateQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method UpdateQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2beta2.Queue.class.getName(),
Exception.class.getName())));
}
@@ -153,7 +153,7 @@ public void updateQueue(
@Override
public void deleteQueue(DeleteQueueRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -165,7 +165,7 @@ public void deleteQueue(DeleteQueueRequest request, StreamObserver respon
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -175,7 +175,7 @@ public void deleteQueue(DeleteQueueRequest request, StreamObserver respon
public void purgeQueue(
PurgeQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2beta2.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2beta2.Queue) response));
@@ -187,7 +187,7 @@ public void purgeQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method PurgeQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2beta2.Queue.class.getName(),
Exception.class.getName())));
}
@@ -197,7 +197,7 @@ public void purgeQueue(
public void pauseQueue(
PauseQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2beta2.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2beta2.Queue) response));
@@ -209,7 +209,7 @@ public void pauseQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method PauseQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2beta2.Queue.class.getName(),
Exception.class.getName())));
}
@@ -219,7 +219,7 @@ public void pauseQueue(
public void resumeQueue(
ResumeQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2beta2.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2beta2.Queue) response));
@@ -231,7 +231,7 @@ public void resumeQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ResumeQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2beta2.Queue.class.getName(),
Exception.class.getName())));
}
@@ -239,7 +239,7 @@ public void resumeQueue(
@Override
public void getIamPolicy(GetIamPolicyRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
@@ -251,7 +251,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetIamPolicy, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Policy.class.getName(),
Exception.class.getName())));
}
@@ -259,7 +259,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver res
@Override
public void setIamPolicy(SetIamPolicyRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
@@ -271,7 +271,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method SetIamPolicy, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Policy.class.getName(),
Exception.class.getName())));
}
@@ -281,7 +281,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver res
public void testIamPermissions(
TestIamPermissionsRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof TestIamPermissionsResponse) {
requests.add(request);
responseObserver.onNext(((TestIamPermissionsResponse) response));
@@ -293,7 +293,7 @@ public void testIamPermissions(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method TestIamPermissions, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
TestIamPermissionsResponse.class.getName(),
Exception.class.getName())));
}
@@ -302,7 +302,7 @@ public void testIamPermissions(
@Override
public void listTasks(
ListTasksRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListTasksResponse) {
requests.add(request);
responseObserver.onNext(((ListTasksResponse) response));
@@ -314,7 +314,7 @@ public void listTasks(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListTasks, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListTasksResponse.class.getName(),
Exception.class.getName())));
}
@@ -322,7 +322,7 @@ public void listTasks(
@Override
public void getTask(GetTaskRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Task) {
requests.add(request);
responseObserver.onNext(((Task) response));
@@ -334,13 +334,15 @@ public void getTask(GetTaskRequest request, StreamObserver responseObserve
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetTask, expected %s or %s",
- response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
+ response == null ? "null" : response.getClass().getName(),
+ Task.class.getName(),
+ Exception.class.getName())));
}
}
@Override
public void createTask(CreateTaskRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Task) {
requests.add(request);
responseObserver.onNext(((Task) response));
@@ -352,13 +354,15 @@ public void createTask(CreateTaskRequest request, StreamObserver responseO
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateTask, expected %s or %s",
- response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
+ response == null ? "null" : response.getClass().getName(),
+ Task.class.getName(),
+ Exception.class.getName())));
}
}
@Override
public void deleteTask(DeleteTaskRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -370,7 +374,7 @@ public void deleteTask(DeleteTaskRequest request, StreamObserver response
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteTask, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -379,7 +383,7 @@ public void deleteTask(DeleteTaskRequest request, StreamObserver response
@Override
public void leaseTasks(
LeaseTasksRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof LeaseTasksResponse) {
requests.add(request);
responseObserver.onNext(((LeaseTasksResponse) response));
@@ -391,7 +395,7 @@ public void leaseTasks(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method LeaseTasks, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
LeaseTasksResponse.class.getName(),
Exception.class.getName())));
}
@@ -400,7 +404,7 @@ public void leaseTasks(
@Override
public void acknowledgeTask(
AcknowledgeTaskRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -412,7 +416,7 @@ public void acknowledgeTask(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method AcknowledgeTask, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -420,7 +424,7 @@ public void acknowledgeTask(
@Override
public void renewLease(RenewLeaseRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Task) {
requests.add(request);
responseObserver.onNext(((Task) response));
@@ -432,13 +436,15 @@ public void renewLease(RenewLeaseRequest request, StreamObserver responseO
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method RenewLease, expected %s or %s",
- response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
+ response == null ? "null" : response.getClass().getName(),
+ Task.class.getName(),
+ Exception.class.getName())));
}
}
@Override
public void cancelLease(CancelLeaseRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Task) {
requests.add(request);
responseObserver.onNext(((Task) response));
@@ -450,13 +456,15 @@ public void cancelLease(CancelLeaseRequest request, StreamObserver respons
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CancelLease, expected %s or %s",
- response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
+ response == null ? "null" : response.getClass().getName(),
+ Task.class.getName(),
+ Exception.class.getName())));
}
}
@Override
public void runTask(RunTaskRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Task) {
requests.add(request);
responseObserver.onNext(((Task) response));
@@ -468,7 +476,9 @@ public void runTask(RunTaskRequest request, StreamObserver responseObserve
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method RunTask, expected %s or %s",
- response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
+ response == null ? "null" : response.getClass().getName(),
+ Task.class.getName(),
+ Exception.class.getName())));
}
}
}
diff --git a/google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2beta3/MockCloudTasksImpl.java b/google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2beta3/MockCloudTasksImpl.java
index de6438e4..e5b306fe 100644
--- a/google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2beta3/MockCloudTasksImpl.java
+++ b/google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2beta3/MockCloudTasksImpl.java
@@ -67,7 +67,7 @@ public void reset() {
@Override
public void listQueues(
ListQueuesRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListQueuesResponse) {
requests.add(request);
responseObserver.onNext(((ListQueuesResponse) response));
@@ -79,7 +79,7 @@ public void listQueues(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListQueues, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListQueuesResponse.class.getName(),
Exception.class.getName())));
}
@@ -89,7 +89,7 @@ public void listQueues(
public void getQueue(
GetQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2beta3.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2beta3.Queue) response));
@@ -101,7 +101,7 @@ public void getQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2beta3.Queue.class.getName(),
Exception.class.getName())));
}
@@ -111,7 +111,7 @@ public void getQueue(
public void createQueue(
CreateQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2beta3.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2beta3.Queue) response));
@@ -123,7 +123,7 @@ public void createQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2beta3.Queue.class.getName(),
Exception.class.getName())));
}
@@ -133,7 +133,7 @@ public void createQueue(
public void updateQueue(
UpdateQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2beta3.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2beta3.Queue) response));
@@ -145,7 +145,7 @@ public void updateQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method UpdateQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2beta3.Queue.class.getName(),
Exception.class.getName())));
}
@@ -153,7 +153,7 @@ public void updateQueue(
@Override
public void deleteQueue(DeleteQueueRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -165,7 +165,7 @@ public void deleteQueue(DeleteQueueRequest request, StreamObserver respon
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -175,7 +175,7 @@ public void deleteQueue(DeleteQueueRequest request, StreamObserver respon
public void purgeQueue(
PurgeQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2beta3.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2beta3.Queue) response));
@@ -187,7 +187,7 @@ public void purgeQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method PurgeQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2beta3.Queue.class.getName(),
Exception.class.getName())));
}
@@ -197,7 +197,7 @@ public void purgeQueue(
public void pauseQueue(
PauseQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2beta3.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2beta3.Queue) response));
@@ -209,7 +209,7 @@ public void pauseQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method PauseQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2beta3.Queue.class.getName(),
Exception.class.getName())));
}
@@ -219,7 +219,7 @@ public void pauseQueue(
public void resumeQueue(
ResumeQueueRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof com.google.cloud.tasks.v2beta3.Queue) {
requests.add(request);
responseObserver.onNext(((com.google.cloud.tasks.v2beta3.Queue) response));
@@ -231,7 +231,7 @@ public void resumeQueue(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ResumeQueue, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
com.google.cloud.tasks.v2beta3.Queue.class.getName(),
Exception.class.getName())));
}
@@ -239,7 +239,7 @@ public void resumeQueue(
@Override
public void getIamPolicy(GetIamPolicyRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
@@ -251,7 +251,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetIamPolicy, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Policy.class.getName(),
Exception.class.getName())));
}
@@ -259,7 +259,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver res
@Override
public void setIamPolicy(SetIamPolicyRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
@@ -271,7 +271,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method SetIamPolicy, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Policy.class.getName(),
Exception.class.getName())));
}
@@ -281,7 +281,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver res
public void testIamPermissions(
TestIamPermissionsRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof TestIamPermissionsResponse) {
requests.add(request);
responseObserver.onNext(((TestIamPermissionsResponse) response));
@@ -293,7 +293,7 @@ public void testIamPermissions(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method TestIamPermissions, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
TestIamPermissionsResponse.class.getName(),
Exception.class.getName())));
}
@@ -302,7 +302,7 @@ public void testIamPermissions(
@Override
public void listTasks(
ListTasksRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListTasksResponse) {
requests.add(request);
responseObserver.onNext(((ListTasksResponse) response));
@@ -314,7 +314,7 @@ public void listTasks(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListTasks, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListTasksResponse.class.getName(),
Exception.class.getName())));
}
@@ -322,7 +322,7 @@ public void listTasks(
@Override
public void getTask(GetTaskRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Task) {
requests.add(request);
responseObserver.onNext(((Task) response));
@@ -334,13 +334,15 @@ public void getTask(GetTaskRequest request, StreamObserver responseObserve
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetTask, expected %s or %s",
- response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
+ response == null ? "null" : response.getClass().getName(),
+ Task.class.getName(),
+ Exception.class.getName())));
}
}
@Override
public void createTask(CreateTaskRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Task) {
requests.add(request);
responseObserver.onNext(((Task) response));
@@ -352,13 +354,15 @@ public void createTask(CreateTaskRequest request, StreamObserver responseO
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateTask, expected %s or %s",
- response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
+ response == null ? "null" : response.getClass().getName(),
+ Task.class.getName(),
+ Exception.class.getName())));
}
}
@Override
public void deleteTask(DeleteTaskRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -370,7 +374,7 @@ public void deleteTask(DeleteTaskRequest request, StreamObserver response
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteTask, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -378,7 +382,7 @@ public void deleteTask(DeleteTaskRequest request, StreamObserver response
@Override
public void runTask(RunTaskRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Task) {
requests.add(request);
responseObserver.onNext(((Task) response));
@@ -390,7 +394,9 @@ public void runTask(RunTaskRequest request, StreamObserver responseObserve
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method RunTask, expected %s or %s",
- response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
+ response == null ? "null" : response.getClass().getName(),
+ Task.class.getName(),
+ Exception.class.getName())));
}
}
}
diff --git a/grpc-google-cloud-tasks-v2/pom.xml b/grpc-google-cloud-tasks-v2/pom.xml
index 42a0ab64..de9ff3f4 100644
--- a/grpc-google-cloud-tasks-v2/pom.xml
+++ b/grpc-google-cloud-tasks-v2/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
grpc-google-cloud-tasks-v2
- 1.32.1
+ 1.32.2
grpc-google-cloud-tasks-v2
GRPC library for grpc-google-cloud-tasks-v2
com.google.cloud
google-cloud-tasks-parent
- 1.32.1
+ 1.32.2
diff --git a/grpc-google-cloud-tasks-v2beta2/pom.xml b/grpc-google-cloud-tasks-v2beta2/pom.xml
index c59b8730..b3d76e05 100644
--- a/grpc-google-cloud-tasks-v2beta2/pom.xml
+++ b/grpc-google-cloud-tasks-v2beta2/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
grpc-google-cloud-tasks-v2beta2
- 0.88.1
+ 0.88.2
grpc-google-cloud-tasks-v2beta2
GRPC library for grpc-google-cloud-tasks-v2beta2
com.google.cloud
google-cloud-tasks-parent
- 1.32.1
+ 1.32.2
diff --git a/grpc-google-cloud-tasks-v2beta3/pom.xml b/grpc-google-cloud-tasks-v2beta3/pom.xml
index dcd178ec..57ed815f 100644
--- a/grpc-google-cloud-tasks-v2beta3/pom.xml
+++ b/grpc-google-cloud-tasks-v2beta3/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
grpc-google-cloud-tasks-v2beta3
- 0.88.1
+ 0.88.2
grpc-google-cloud-tasks-v2beta3
GRPC library for grpc-google-cloud-tasks-v2beta3
com.google.cloud
google-cloud-tasks-parent
- 1.32.1
+ 1.32.2
diff --git a/pom.xml b/pom.xml
index e3562624..4b4916cf 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
com.google.cloud
google-cloud-tasks-parent
pom
- 1.32.1
+ 1.32.2
Google Cloud Tasks Parent
https://github.com/googleapis/java-tasks
@@ -70,43 +70,43 @@
com.google.api.grpc
proto-google-cloud-tasks-v2beta3
- 0.88.1
+ 0.88.2
com.google.api.grpc
proto-google-cloud-tasks-v2beta2
- 0.88.1
+ 0.88.2
com.google.api.grpc
proto-google-cloud-tasks-v2
- 1.32.1
+ 1.32.2
com.google.api.grpc
grpc-google-cloud-tasks-v2beta3
- 0.88.1
+ 0.88.2
com.google.api.grpc
grpc-google-cloud-tasks-v2beta2
- 0.88.1
+ 0.88.2
com.google.api.grpc
grpc-google-cloud-tasks-v2
- 1.32.1
+ 1.32.2
com.google.cloud
google-cloud-tasks
- 1.32.1
+ 1.32.2
com.google.cloud
google-cloud-shared-dependencies
- 0.20.1
+ 0.21.0
pom
import
diff --git a/proto-google-cloud-tasks-v2/pom.xml b/proto-google-cloud-tasks-v2/pom.xml
index 643a51fb..eabc2424 100644
--- a/proto-google-cloud-tasks-v2/pom.xml
+++ b/proto-google-cloud-tasks-v2/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
proto-google-cloud-tasks-v2
- 1.32.1
+ 1.32.2
proto-google-cloud-tasks-v2
PROTO library for proto-google-cloud-tasks-v2
com.google.cloud
google-cloud-tasks-parent
- 1.32.1
+ 1.32.2
diff --git a/proto-google-cloud-tasks-v2beta2/pom.xml b/proto-google-cloud-tasks-v2beta2/pom.xml
index 287a6e54..6c11820c 100644
--- a/proto-google-cloud-tasks-v2beta2/pom.xml
+++ b/proto-google-cloud-tasks-v2beta2/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
proto-google-cloud-tasks-v2beta2
- 0.88.1
+ 0.88.2
proto-google-cloud-tasks-v2beta2
PROTO library for proto-google-cloud-tasks-v2beta2
com.google.cloud
google-cloud-tasks-parent
- 1.32.1
+ 1.32.2
diff --git a/proto-google-cloud-tasks-v2beta3/pom.xml b/proto-google-cloud-tasks-v2beta3/pom.xml
index 47cf5370..0e0a21ef 100644
--- a/proto-google-cloud-tasks-v2beta3/pom.xml
+++ b/proto-google-cloud-tasks-v2beta3/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
proto-google-cloud-tasks-v2beta3
- 0.88.1
+ 0.88.2
proto-google-cloud-tasks-v2beta3
PROTO library for proto-google-cloud-tasks-v2beta3
com.google.cloud
google-cloud-tasks-parent
- 1.32.1
+ 1.32.2
diff --git a/samples/install-without-bom/pom.xml b/samples/install-without-bom/pom.xml
index 01d62e36..54d32c00 100644
--- a/samples/install-without-bom/pom.xml
+++ b/samples/install-without-bom/pom.xml
@@ -14,7 +14,7 @@
com.google.cloud.samples
shared-configuration
- 1.0.21
+ 1.0.22
@@ -29,7 +29,7 @@
com.google.cloud
google-cloud-tasks
- 1.31.1
+ 1.32.1
diff --git a/samples/pom.xml b/samples/pom.xml
index 9ef38493..3bff0f0b 100644
--- a/samples/pom.xml
+++ b/samples/pom.xml
@@ -18,7 +18,7 @@
com.google.cloud.samples
shared-configuration
- 1.0.21
+ 1.0.22
diff --git a/samples/snapshot/pom.xml b/samples/snapshot/pom.xml
index ea1c61e0..1f765523 100644
--- a/samples/snapshot/pom.xml
+++ b/samples/snapshot/pom.xml
@@ -14,7 +14,7 @@
com.google.cloud.samples
shared-configuration
- 1.0.21
+ 1.0.22
@@ -28,7 +28,7 @@
com.google.cloud
google-cloud-tasks
- 1.31.1
+ 1.32.1
diff --git a/samples/snippets/pom.xml b/samples/snippets/pom.xml
index a2a99baf..fa9f9f0f 100644
--- a/samples/snippets/pom.xml
+++ b/samples/snippets/pom.xml
@@ -14,7 +14,7 @@
com.google.cloud.samples
shared-configuration
- 1.0.21
+ 1.0.22
@@ -30,7 +30,7 @@
com.google.cloud
libraries-bom
- 19.0.0
+ 19.2.1
pom
import
diff --git a/synth.metadata b/synth.metadata
index 1d75e6dc..1802c0f9 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -4,22 +4,22 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/java-tasks.git",
- "sha": "3ffde2787a5b6df57f775c882a696fd59d64b459"
+ "sha": "a4d01dc922a12862fec4084afd9d9241a01cb194"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "0e915217fb5261c1e57bfaf0e16ee5c7feaaba89",
- "internalRef": "361377784"
+ "sha": "1305ca41d554eb0725237561e34129373bb8cbc1",
+ "internalRef": "362856902"
}
},
{
"git": {
"name": "synthtool",
"remote": "https://github.com/googleapis/synthtool.git",
- "sha": "0b064d767537e0675fc053e53fca473c5c701fb8"
+ "sha": "5b0e1592dd7d70b485e157ea4b3eb1704ecbd015"
}
}
],
diff --git a/versions.txt b/versions.txt
index 70a50456..19c31197 100644
--- a/versions.txt
+++ b/versions.txt
@@ -1,10 +1,10 @@
# Format:
# module:released-version:current-version
-proto-google-cloud-tasks-v2beta3:0.88.1:0.88.1
-proto-google-cloud-tasks-v2beta2:0.88.1:0.88.1
-proto-google-cloud-tasks-v2:1.32.1:1.32.1
-grpc-google-cloud-tasks-v2beta3:0.88.1:0.88.1
-grpc-google-cloud-tasks-v2beta2:0.88.1:0.88.1
-grpc-google-cloud-tasks-v2:1.32.1:1.32.1
-google-cloud-tasks:1.32.1:1.32.1
\ No newline at end of file
+proto-google-cloud-tasks-v2beta3:0.88.2:0.88.2
+proto-google-cloud-tasks-v2beta2:0.88.2:0.88.2
+proto-google-cloud-tasks-v2:1.32.2:1.32.2
+grpc-google-cloud-tasks-v2beta3:0.88.2:0.88.2
+grpc-google-cloud-tasks-v2beta2:0.88.2:0.88.2
+grpc-google-cloud-tasks-v2:1.32.2:1.32.2
+google-cloud-tasks:1.32.2:1.32.2
\ No newline at end of file