Skip to content
This repository was archived by the owner on Sep 16, 2023. It is now read-only.

Commit 02a7f90

Browse files
yoshi-automationyoshi-automation
authored
chore: update java microgenerator to 1.0.2 Adds request initialization to sample code (#394)
This PR was generated using Autosynth. 🌈 Synth log will be available here: https://source.cloud.google.com/results/invocations/2c9cca4a-366c-4c22-a332-9048b732edf6/targets - [ ] To automatically regenerate this PR, check this box. PiperOrigin-RevId: 362856902 Source-Link: googleapis/googleapis@1305ca4
1 parent ba6e441 commit 02a7f90

File tree

7 files changed

+170
-107
lines changed

7 files changed

+170
-107
lines changed

‎google-cloud-tasks/src/main/java/com/google/cloud/tasks/v2/CloudTasksClient.java

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -276,6 +276,13 @@ public final UnaryCallable<ListQueuesRequest, ListQueuesPagedResponse> listQueue
276276
*
277277
* <pre>{@code
278278
* try (CloudTasksClient cloudTasksClient = CloudTasksClient.create()) {
279+
* ListQueuesRequest request =
280+
* ListQueuesRequest.newBuilder()
281+
* .setParent(QueueName.of("[PROJECT]", "[LOCATION]", "[QUEUE]").toString())
282+
* .setFilter("filter-1274492040")
283+
* .setPageSize(883849137)
284+
* .setPageToken("pageToken873572522")
285+
* .build();
279286
* while (true) {
280287
* ListQueuesResponse response = cloudTasksClient.listQueuesCallable().call(request);
281288
* for (Queue element : response.getResponsesList()) {
@@ -1665,6 +1672,12 @@ public final UnaryCallable<ListTasksRequest, ListTasksPagedResponse> listTasksPa
16651672
*
16661673
* <pre>{@code
16671674
* try (CloudTasksClient cloudTasksClient = CloudTasksClient.create()) {
1675+
* ListTasksRequest request =
1676+
* ListTasksRequest.newBuilder()
1677+
* .setParent(TaskName.of("[PROJECT]", "[LOCATION]", "[QUEUE]", "[TASK]").toString())
1678+
* .setPageSize(883849137)
1679+
* .setPageToken("pageToken873572522")
1680+
* .build();
16681681
* while (true) {
16691682
* ListTasksResponse response = cloudTasksClient.listTasksCallable().call(request);
16701683
* for (Task element : response.getResponsesList()) {

‎google-cloud-tasks/src/main/java/com/google/cloud/tasks/v2beta2/CloudTasksClient.java

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -281,6 +281,14 @@ public final UnaryCallable<ListQueuesRequest, ListQueuesPagedResponse> listQueue
281281
*
282282
* <pre>{@code
283283
* try (CloudTasksClient cloudTasksClient = CloudTasksClient.create()) {
284+
* ListQueuesRequest request =
285+
* ListQueuesRequest.newBuilder()
286+
* .setParent(QueueName.of("[PROJECT]", "[LOCATION]", "[QUEUE]").toString())
287+
* .setFilter("filter-1274492040")
288+
* .setPageSize(883849137)
289+
* .setPageToken("pageToken873572522")
290+
* .setReadMask(FieldMask.newBuilder().build())
291+
* .build();
284292
* while (true) {
285293
* ListQueuesResponse response = cloudTasksClient.listQueuesCallable().call(request);
286294
* for (Queue element : response.getResponsesList()) {
@@ -1676,6 +1684,12 @@ public final UnaryCallable<ListTasksRequest, ListTasksPagedResponse> listTasksPa
16761684
*
16771685
* <pre>{@code
16781686
* try (CloudTasksClient cloudTasksClient = CloudTasksClient.create()) {
1687+
* ListTasksRequest request =
1688+
* ListTasksRequest.newBuilder()
1689+
* .setParent(TaskName.of("[PROJECT]", "[LOCATION]", "[QUEUE]", "[TASK]").toString())
1690+
* .setPageSize(883849137)
1691+
* .setPageToken("pageToken873572522")
1692+
* .build();
16791693
* while (true) {
16801694
* ListTasksResponse response = cloudTasksClient.listTasksCallable().call(request);
16811695
* for (Task element : response.getResponsesList()) {

‎google-cloud-tasks/src/main/java/com/google/cloud/tasks/v2beta3/CloudTasksClient.java

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -279,6 +279,14 @@ public final UnaryCallable<ListQueuesRequest, ListQueuesPagedResponse> listQueue
279279
*
280280
* <pre>{@code
281281
* try (CloudTasksClient cloudTasksClient = CloudTasksClient.create()) {
282+
* ListQueuesRequest request =
283+
* ListQueuesRequest.newBuilder()
284+
* .setParent(QueueName.of("[PROJECT]", "[LOCATION]", "[QUEUE]").toString())
285+
* .setFilter("filter-1274492040")
286+
* .setPageSize(883849137)
287+
* .setPageToken("pageToken873572522")
288+
* .setReadMask(FieldMask.newBuilder().build())
289+
* .build();
282290
* while (true) {
283291
* ListQueuesResponse response = cloudTasksClient.listQueuesCallable().call(request);
284292
* for (Queue element : response.getResponsesList()) {
@@ -1674,6 +1682,12 @@ public final UnaryCallable<ListTasksRequest, ListTasksPagedResponse> listTasksPa
16741682
*
16751683
* <pre>{@code
16761684
* try (CloudTasksClient cloudTasksClient = CloudTasksClient.create()) {
1685+
* ListTasksRequest request =
1686+
* ListTasksRequest.newBuilder()
1687+
* .setParent(TaskName.of("[PROJECT]", "[LOCATION]", "[QUEUE]", "[TASK]").toString())
1688+
* .setPageSize(883849137)
1689+
* .setPageToken("pageToken873572522")
1690+
* .build();
16771691
* while (true) {
16781692
* ListTasksResponse response = cloudTasksClient.listTasksCallable().call(request);
16791693
* for (Task element : response.getResponsesList()) {

‎google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2/MockCloudTasksImpl.java

Lines changed: 38 additions & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ public void reset() {
6767
@Override
6868
public void listQueues(
6969
ListQueuesRequest request, StreamObserver<ListQueuesResponse> responseObserver) {
70-
Object response = responses.remove();
70+
Object response = responses.poll();
7171
if (response instanceof ListQueuesResponse) {
7272
requests.add(request);
7373
responseObserver.onNext(((ListQueuesResponse) response));
@@ -79,7 +79,7 @@ public void listQueues(
7979
new IllegalArgumentException(
8080
String.format(
8181
"Unrecognized response type %s for method ListQueues, expected %s or %s",
82-
response.getClass().getName(),
82+
response == null ? "null" : response.getClass().getName(),
8383
ListQueuesResponse.class.getName(),
8484
Exception.class.getName())));
8585
}
@@ -88,7 +88,7 @@ public void listQueues(
8888
@Override
8989
public void getQueue(
9090
GetQueueRequest request, StreamObserver<com.google.cloud.tasks.v2.Queue> responseObserver) {
91-
Object response = responses.remove();
91+
Object response = responses.poll();
9292
if (response instanceof com.google.cloud.tasks.v2.Queue) {
9393
requests.add(request);
9494
responseObserver.onNext(((com.google.cloud.tasks.v2.Queue) response));
@@ -100,7 +100,7 @@ public void getQueue(
100100
new IllegalArgumentException(
101101
String.format(
102102
"Unrecognized response type %s for method GetQueue, expected %s or %s",
103-
response.getClass().getName(),
103+
response == null ? "null" : response.getClass().getName(),
104104
com.google.cloud.tasks.v2.Queue.class.getName(),
105105
Exception.class.getName())));
106106
}
@@ -110,7 +110,7 @@ public void getQueue(
110110
public void createQueue(
111111
CreateQueueRequest request,
112112
StreamObserver<com.google.cloud.tasks.v2.Queue> responseObserver) {
113-
Object response = responses.remove();
113+
Object response = responses.poll();
114114
if (response instanceof com.google.cloud.tasks.v2.Queue) {
115115
requests.add(request);
116116
responseObserver.onNext(((com.google.cloud.tasks.v2.Queue) response));
@@ -122,7 +122,7 @@ public void createQueue(
122122
new IllegalArgumentException(
123123
String.format(
124124
"Unrecognized response type %s for method CreateQueue, expected %s or %s",
125-
response.getClass().getName(),
125+
response == null ? "null" : response.getClass().getName(),
126126
com.google.cloud.tasks.v2.Queue.class.getName(),
127127
Exception.class.getName())));
128128
}
@@ -132,7 +132,7 @@ public void createQueue(
132132
public void updateQueue(
133133
UpdateQueueRequest request,
134134
StreamObserver<com.google.cloud.tasks.v2.Queue> responseObserver) {
135-
Object response = responses.remove();
135+
Object response = responses.poll();
136136
if (response instanceof com.google.cloud.tasks.v2.Queue) {
137137
requests.add(request);
138138
responseObserver.onNext(((com.google.cloud.tasks.v2.Queue) response));
@@ -144,15 +144,15 @@ public void updateQueue(
144144
new IllegalArgumentException(
145145
String.format(
146146
"Unrecognized response type %s for method UpdateQueue, expected %s or %s",
147-
response.getClass().getName(),
147+
response == null ? "null" : response.getClass().getName(),
148148
com.google.cloud.tasks.v2.Queue.class.getName(),
149149
Exception.class.getName())));
150150
}
151151
}
152152

153153
@Override
154154
public void deleteQueue(DeleteQueueRequest request, StreamObserver<Empty> responseObserver) {
155-
Object response = responses.remove();
155+
Object response = responses.poll();
156156
if (response instanceof Empty) {
157157
requests.add(request);
158158
responseObserver.onNext(((Empty) response));
@@ -164,7 +164,7 @@ public void deleteQueue(DeleteQueueRequest request, StreamObserver<Empty> respon
164164
new IllegalArgumentException(
165165
String.format(
166166
"Unrecognized response type %s for method DeleteQueue, expected %s or %s",
167-
response.getClass().getName(),
167+
response == null ? "null" : response.getClass().getName(),
168168
Empty.class.getName(),
169169
Exception.class.getName())));
170170
}
@@ -173,7 +173,7 @@ public void deleteQueue(DeleteQueueRequest request, StreamObserver<Empty> respon
173173
@Override
174174
public void purgeQueue(
175175
PurgeQueueRequest request, StreamObserver<com.google.cloud.tasks.v2.Queue> responseObserver) {
176-
Object response = responses.remove();
176+
Object response = responses.poll();
177177
if (response instanceof com.google.cloud.tasks.v2.Queue) {
178178
requests.add(request);
179179
responseObserver.onNext(((com.google.cloud.tasks.v2.Queue) response));
@@ -185,7 +185,7 @@ public void purgeQueue(
185185
new IllegalArgumentException(
186186
String.format(
187187
"Unrecognized response type %s for method PurgeQueue, expected %s or %s",
188-
response.getClass().getName(),
188+
response == null ? "null" : response.getClass().getName(),
189189
com.google.cloud.tasks.v2.Queue.class.getName(),
190190
Exception.class.getName())));
191191
}
@@ -194,7 +194,7 @@ public void purgeQueue(
194194
@Override
195195
public void pauseQueue(
196196
PauseQueueRequest request, StreamObserver<com.google.cloud.tasks.v2.Queue> responseObserver) {
197-
Object response = responses.remove();
197+
Object response = responses.poll();
198198
if (response instanceof com.google.cloud.tasks.v2.Queue) {
199199
requests.add(request);
200200
responseObserver.onNext(((com.google.cloud.tasks.v2.Queue) response));
@@ -206,7 +206,7 @@ public void pauseQueue(
206206
new IllegalArgumentException(
207207
String.format(
208208
"Unrecognized response type %s for method PauseQueue, expected %s or %s",
209-
response.getClass().getName(),
209+
response == null ? "null" : response.getClass().getName(),
210210
com.google.cloud.tasks.v2.Queue.class.getName(),
211211
Exception.class.getName())));
212212
}
@@ -216,7 +216,7 @@ public void pauseQueue(
216216
public void resumeQueue(
217217
ResumeQueueRequest request,
218218
StreamObserver<com.google.cloud.tasks.v2.Queue> responseObserver) {
219-
Object response = responses.remove();
219+
Object response = responses.poll();
220220
if (response instanceof com.google.cloud.tasks.v2.Queue) {
221221
requests.add(request);
222222
responseObserver.onNext(((com.google.cloud.tasks.v2.Queue) response));
@@ -228,15 +228,15 @@ public void resumeQueue(
228228
new IllegalArgumentException(
229229
String.format(
230230
"Unrecognized response type %s for method ResumeQueue, expected %s or %s",
231-
response.getClass().getName(),
231+
response == null ? "null" : response.getClass().getName(),
232232
com.google.cloud.tasks.v2.Queue.class.getName(),
233233
Exception.class.getName())));
234234
}
235235
}
236236

237237
@Override
238238
public void getIamPolicy(GetIamPolicyRequest request, StreamObserver<Policy> responseObserver) {
239-
Object response = responses.remove();
239+
Object response = responses.poll();
240240
if (response instanceof Policy) {
241241
requests.add(request);
242242
responseObserver.onNext(((Policy) response));
@@ -248,15 +248,15 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver<Policy> res
248248
new IllegalArgumentException(
249249
String.format(
250250
"Unrecognized response type %s for method GetIamPolicy, expected %s or %s",
251-
response.getClass().getName(),
251+
response == null ? "null" : response.getClass().getName(),
252252
Policy.class.getName(),
253253
Exception.class.getName())));
254254
}
255255
}
256256

257257
@Override
258258
public void setIamPolicy(SetIamPolicyRequest request, StreamObserver<Policy> responseObserver) {
259-
Object response = responses.remove();
259+
Object response = responses.poll();
260260
if (response instanceof Policy) {
261261
requests.add(request);
262262
responseObserver.onNext(((Policy) response));
@@ -268,7 +268,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver<Policy> res
268268
new IllegalArgumentException(
269269
String.format(
270270
"Unrecognized response type %s for method SetIamPolicy, expected %s or %s",
271-
response.getClass().getName(),
271+
response == null ? "null" : response.getClass().getName(),
272272
Policy.class.getName(),
273273
Exception.class.getName())));
274274
}
@@ -278,7 +278,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver<Policy> res
278278
public void testIamPermissions(
279279
TestIamPermissionsRequest request,
280280
StreamObserver<TestIamPermissionsResponse> responseObserver) {
281-
Object response = responses.remove();
281+
Object response = responses.poll();
282282
if (response instanceof TestIamPermissionsResponse) {
283283
requests.add(request);
284284
responseObserver.onNext(((TestIamPermissionsResponse) response));
@@ -290,7 +290,7 @@ public void testIamPermissions(
290290
new IllegalArgumentException(
291291
String.format(
292292
"Unrecognized response type %s for method TestIamPermissions, expected %s or %s",
293-
response.getClass().getName(),
293+
response == null ? "null" : response.getClass().getName(),
294294
TestIamPermissionsResponse.class.getName(),
295295
Exception.class.getName())));
296296
}
@@ -299,7 +299,7 @@ public void testIamPermissions(
299299
@Override
300300
public void listTasks(
301301
ListTasksRequest request, StreamObserver<ListTasksResponse> responseObserver) {
302-
Object response = responses.remove();
302+
Object response = responses.poll();
303303
if (response instanceof ListTasksResponse) {
304304
requests.add(request);
305305
responseObserver.onNext(((ListTasksResponse) response));
@@ -311,15 +311,15 @@ public void listTasks(
311311
new IllegalArgumentException(
312312
String.format(
313313
"Unrecognized response type %s for method ListTasks, expected %s or %s",
314-
response.getClass().getName(),
314+
response == null ? "null" : response.getClass().getName(),
315315
ListTasksResponse.class.getName(),
316316
Exception.class.getName())));
317317
}
318318
}
319319

320320
@Override
321321
public void getTask(GetTaskRequest request, StreamObserver<Task> responseObserver) {
322-
Object response = responses.remove();
322+
Object response = responses.poll();
323323
if (response instanceof Task) {
324324
requests.add(request);
325325
responseObserver.onNext(((Task) response));
@@ -331,13 +331,15 @@ public void getTask(GetTaskRequest request, StreamObserver<Task> responseObserve
331331
new IllegalArgumentException(
332332
String.format(
333333
"Unrecognized response type %s for method GetTask, expected %s or %s",
334-
response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
334+
response == null ? "null" : response.getClass().getName(),
335+
Task.class.getName(),
336+
Exception.class.getName())));
335337
}
336338
}
337339

338340
@Override
339341
public void createTask(CreateTaskRequest request, StreamObserver<Task> responseObserver) {
340-
Object response = responses.remove();
342+
Object response = responses.poll();
341343
if (response instanceof Task) {
342344
requests.add(request);
343345
responseObserver.onNext(((Task) response));
@@ -349,13 +351,15 @@ public void createTask(CreateTaskRequest request, StreamObserver<Task> responseO
349351
new IllegalArgumentException(
350352
String.format(
351353
"Unrecognized response type %s for method CreateTask, expected %s or %s",
352-
response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
354+
response == null ? "null" : response.getClass().getName(),
355+
Task.class.getName(),
356+
Exception.class.getName())));
353357
}
354358
}
355359

356360
@Override
357361
public void deleteTask(DeleteTaskRequest request, StreamObserver<Empty> responseObserver) {
358-
Object response = responses.remove();
362+
Object response = responses.poll();
359363
if (response instanceof Empty) {
360364
requests.add(request);
361365
responseObserver.onNext(((Empty) response));
@@ -367,15 +371,15 @@ public void deleteTask(DeleteTaskRequest request, StreamObserver<Empty> response
367371
new IllegalArgumentException(
368372
String.format(
369373
"Unrecognized response type %s for method DeleteTask, expected %s or %s",
370-
response.getClass().getName(),
374+
response == null ? "null" : response.getClass().getName(),
371375
Empty.class.getName(),
372376
Exception.class.getName())));
373377
}
374378
}
375379

376380
@Override
377381
public void runTask(RunTaskRequest request, StreamObserver<Task> responseObserver) {
378-
Object response = responses.remove();
382+
Object response = responses.poll();
379383
if (response instanceof Task) {
380384
requests.add(request);
381385
responseObserver.onNext(((Task) response));
@@ -387,7 +391,9 @@ public void runTask(RunTaskRequest request, StreamObserver<Task> responseObserve
387391
new IllegalArgumentException(
388392
String.format(
389393
"Unrecognized response type %s for method RunTask, expected %s or %s",
390-
response.getClass().getName(), Task.class.getName(), Exception.class.getName())));
394+
response == null ? "null" : response.getClass().getName(),
395+
Task.class.getName(),
396+
Exception.class.getName())));
391397
}
392398
}
393399
}

0 commit comments

Comments
 (0)