Class CloudTasksClient (2.2.0)

publicclass CloudTasksClientimplementsBackgroundResource

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
QueueNamename=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]");
Queueresponse=cloudTasksClient.getQueue(name);
}

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
CloudTasksSettingscloudTasksSettings=
CloudTasksSettings.newBuilder()
.setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
.build();
CloudTasksClientcloudTasksClient=CloudTasksClient.create(cloudTasksSettings);

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
CloudTasksSettingscloudTasksSettings=
CloudTasksSettings.newBuilder().setEndpoint(myEndpoint).build();
CloudTasksClientcloudTasksClient=CloudTasksClient.create(cloudTasksSettings);

publicstaticfinalCloudTasksClientcreate()

publicstaticfinalCloudTasksClientcreate(CloudTasksSettingssettings)

publicstaticfinalCloudTasksClientcreate(CloudTasksStubstub)

protectedCloudTasksClient(CloudTasksSettingssettings)

protectedCloudTasksClient(CloudTasksStubstub)

publicfinalvoidacknowledgeTask(AcknowledgeTaskRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
AcknowledgeTaskRequestrequest=
AcknowledgeTaskRequest.newBuilder()
.setName(TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString())
.setScheduleTime(Timestamp.newBuilder().build())
.build();
cloudTasksClient.acknowledgeTask(request);
}

publicfinalvoidacknowledgeTask(TaskNamename,TimestampscheduleTime)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
TaskNamename=TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]");
TimestampscheduleTime=Timestamp.newBuilder().build();
cloudTasksClient.acknowledgeTask(name,scheduleTime);
}

publicfinalvoidacknowledgeTask(Stringname,TimestampscheduleTime)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringname=TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString();
TimestampscheduleTime=Timestamp.newBuilder().build();
cloudTasksClient.acknowledgeTask(name,scheduleTime);
}

publicfinalUnaryCallable<AcknowledgeTaskRequest,Empty>acknowledgeTaskCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
AcknowledgeTaskRequestrequest=
AcknowledgeTaskRequest.newBuilder()
.setName(TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString())
.setScheduleTime(Timestamp.newBuilder().build())
.build();
ApiFuture<Empty>future=cloudTasksClient.acknowledgeTaskCallable().futureCall(request);
// Do something.
future.get();
}

publicbooleanawaitTermination(longduration,TimeUnitunit)

publicfinalTaskcancelLease(CancelLeaseRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
CancelLeaseRequestrequest=
CancelLeaseRequest.newBuilder()
.setName(TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString())
.setScheduleTime(Timestamp.newBuilder().build())
.build();
Taskresponse=cloudTasksClient.cancelLease(request);
}

publicfinalTaskcancelLease(TaskNamename,TimestampscheduleTime)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
TaskNamename=TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]");
TimestampscheduleTime=Timestamp.newBuilder().build();
Taskresponse=cloudTasksClient.cancelLease(name,scheduleTime);
}

publicfinalTaskcancelLease(Stringname,TimestampscheduleTime)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringname=TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString();
TimestampscheduleTime=Timestamp.newBuilder().build();
Taskresponse=cloudTasksClient.cancelLease(name,scheduleTime);
}

publicfinalUnaryCallable<CancelLeaseRequest,Task>cancelLeaseCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
CancelLeaseRequestrequest=
CancelLeaseRequest.newBuilder()
.setName(TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString())
.setScheduleTime(Timestamp.newBuilder().build())
.build();
ApiFuture<Task>future=cloudTasksClient.cancelLeaseCallable().futureCall(request);
// Do something.
Taskresponse=future.get();
}

publicfinalvoidclose()

publicfinalQueuecreateQueue(CreateQueueRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
CreateQueueRequestrequest=
CreateQueueRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setQueue(Queue.newBuilder().build())
.build();
Queueresponse=cloudTasksClient.createQueue(request);
}

publicfinalQueuecreateQueue(LocationNameparent,Queuequeue)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
LocationNameparent=LocationName.of("[PROJECT]","[LOCATION]");
Queuequeue=Queue.newBuilder().build();
Queueresponse=cloudTasksClient.createQueue(parent,queue);
}

publicfinalQueuecreateQueue(Stringparent,Queuequeue)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringparent=LocationName.of("[PROJECT]","[LOCATION]").toString();
Queuequeue=Queue.newBuilder().build();
Queueresponse=cloudTasksClient.createQueue(parent,queue);
}

publicfinalUnaryCallable<CreateQueueRequest,Queue>createQueueCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
CreateQueueRequestrequest=
CreateQueueRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setQueue(Queue.newBuilder().build())
.build();
ApiFuture<Queue>future=cloudTasksClient.createQueueCallable().futureCall(request);
// Do something.
Queueresponse=future.get();
}

publicfinalTaskcreateTask(CreateTaskRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
CreateTaskRequestrequest=
CreateTaskRequest.newBuilder()
.setParent(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.setTask(Task.newBuilder().build())
.build();
Taskresponse=cloudTasksClient.createTask(request);
}

publicfinalTaskcreateTask(QueueNameparent,Tasktask)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
QueueNameparent=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]");
Tasktask=Task.newBuilder().build();
Taskresponse=cloudTasksClient.createTask(parent,task);
}

publicfinalTaskcreateTask(Stringparent,Tasktask)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringparent=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString();
Tasktask=Task.newBuilder().build();
Taskresponse=cloudTasksClient.createTask(parent,task);
}

publicfinalUnaryCallable<CreateTaskRequest,Task>createTaskCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
CreateTaskRequestrequest=
CreateTaskRequest.newBuilder()
.setParent(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.setTask(Task.newBuilder().build())
.build();
ApiFuture<Task>future=cloudTasksClient.createTaskCallable().futureCall(request);
// Do something.
Taskresponse=future.get();
}

publicfinalvoiddeleteQueue(DeleteQueueRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
DeleteQueueRequestrequest=
DeleteQueueRequest.newBuilder()
.setName(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.build();
cloudTasksClient.deleteQueue(request);
}

publicfinalvoiddeleteQueue(QueueNamename)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
QueueNamename=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]");
cloudTasksClient.deleteQueue(name);
}

publicfinalvoiddeleteQueue(Stringname)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringname=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString();
cloudTasksClient.deleteQueue(name);
}

publicfinalUnaryCallable<DeleteQueueRequest,Empty>deleteQueueCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
DeleteQueueRequestrequest=
DeleteQueueRequest.newBuilder()
.setName(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.build();
ApiFuture<Empty>future=cloudTasksClient.deleteQueueCallable().futureCall(request);
// Do something.
future.get();
}

publicfinalvoiddeleteTask(DeleteTaskRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
DeleteTaskRequestrequest=
DeleteTaskRequest.newBuilder()
.setName(TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString())
.build();
cloudTasksClient.deleteTask(request);
}

publicfinalvoiddeleteTask(TaskNamename)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
TaskNamename=TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]");
cloudTasksClient.deleteTask(name);
}

publicfinalvoiddeleteTask(Stringname)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringname=TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString();
cloudTasksClient.deleteTask(name);
}

publicfinalUnaryCallable<DeleteTaskRequest,Empty>deleteTaskCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
DeleteTaskRequestrequest=
DeleteTaskRequest.newBuilder()
.setName(TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString())
.build();
ApiFuture<Empty>future=cloudTasksClient.deleteTaskCallable().futureCall(request);
// Do something.
future.get();
}

publicfinalPolicygetIamPolicy(ResourceNameresource)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
ResourceNameresource=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]");
Policyresponse=cloudTasksClient.getIamPolicy(resource);
}

publicfinalPolicygetIamPolicy(QueueNamequeueName)

publicfinalPolicygetIamPolicy(GetIamPolicyRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
GetIamPolicyRequestrequest=
GetIamPolicyRequest.newBuilder()
.setResource(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.setOptions(GetPolicyOptions.newBuilder().build())
.build();
Policyresponse=cloudTasksClient.getIamPolicy(request);
}

publicfinalPolicygetIamPolicy(Stringresource)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringresource=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString();
Policyresponse=cloudTasksClient.getIamPolicy(resource);
}

publicfinalUnaryCallable<GetIamPolicyRequest,Policy>getIamPolicyCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
GetIamPolicyRequestrequest=
GetIamPolicyRequest.newBuilder()
.setResource(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.setOptions(GetPolicyOptions.newBuilder().build())
.build();
ApiFuture<Policy>future=cloudTasksClient.getIamPolicyCallable().futureCall(request);
// Do something.
Policyresponse=future.get();
}

publicfinalQueuegetQueue(GetQueueRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
GetQueueRequestrequest=
GetQueueRequest.newBuilder()
.setName(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.setReadMask(FieldMask.newBuilder().build())
.build();
Queueresponse=cloudTasksClient.getQueue(request);
}

publicfinalQueuegetQueue(QueueNamename)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
QueueNamename=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]");
Queueresponse=cloudTasksClient.getQueue(name);
}

publicfinalQueuegetQueue(Stringname)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringname=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString();
Queueresponse=cloudTasksClient.getQueue(name);
}

publicfinalUnaryCallable<GetQueueRequest,Queue>getQueueCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
GetQueueRequestrequest=
GetQueueRequest.newBuilder()
.setName(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.setReadMask(FieldMask.newBuilder().build())
.build();
ApiFuture<Queue>future=cloudTasksClient.getQueueCallable().futureCall(request);
// Do something.
Queueresponse=future.get();
}

publicfinalCloudTasksSettingsgetSettings()

publicCloudTasksStubgetStub()

publicfinalTaskgetTask(GetTaskRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
GetTaskRequestrequest=
GetTaskRequest.newBuilder()
.setName(TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString())
.build();
Taskresponse=cloudTasksClient.getTask(request);
}

publicfinalTaskgetTask(TaskNamename)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
TaskNamename=TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]");
Taskresponse=cloudTasksClient.getTask(name);
}

publicfinalTaskgetTask(Stringname)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringname=TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString();
Taskresponse=cloudTasksClient.getTask(name);
}

publicfinalUnaryCallable<GetTaskRequest,Task>getTaskCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
GetTaskRequestrequest=
GetTaskRequest.newBuilder()
.setName(TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString())
.build();
ApiFuture<Task>future=cloudTasksClient.getTaskCallable().futureCall(request);
// Do something.
Taskresponse=future.get();
}

publicbooleanisShutdown()

publicbooleanisTerminated()

publicfinalLeaseTasksResponseleaseTasks(LeaseTasksRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
LeaseTasksRequestrequest=
LeaseTasksRequest.newBuilder()
.setParent(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.setMaxTasks(-233969421)
.setLeaseDuration(Duration.newBuilder().build())
.setFilter("filter-1274492040")
.build();
LeaseTasksResponseresponse=cloudTasksClient.leaseTasks(request);
}

publicfinalLeaseTasksResponseleaseTasks(QueueNameparent,DurationleaseDuration)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
QueueNameparent=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]");
DurationleaseDuration=Duration.newBuilder().build();
LeaseTasksResponseresponse=cloudTasksClient.leaseTasks(parent,leaseDuration);
}

publicfinalLeaseTasksResponseleaseTasks(Stringparent,DurationleaseDuration)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringparent=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString();
DurationleaseDuration=Duration.newBuilder().build();
LeaseTasksResponseresponse=cloudTasksClient.leaseTasks(parent,leaseDuration);
}

publicfinalUnaryCallable<LeaseTasksRequest,LeaseTasksResponse>leaseTasksCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
LeaseTasksRequestrequest=
LeaseTasksRequest.newBuilder()
.setParent(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.setMaxTasks(-233969421)
.setLeaseDuration(Duration.newBuilder().build())
.setFilter("filter-1274492040")
.build();
ApiFuture<LeaseTasksResponse>future=
cloudTasksClient.leaseTasksCallable().futureCall(request);
// Do something.
LeaseTasksResponseresponse=future.get();
}

publicfinalCloudTasksClient.ListQueuesPagedResponselistQueues(ListQueuesRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
ListQueuesRequestrequest=
ListQueuesRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setFilter("filter-1274492040")
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setReadMask(FieldMask.newBuilder().build())
.build();
for(Queueelement:cloudTasksClient.listQueues(request).iterateAll()){
// doThingsWith(element);
}
}

publicfinalCloudTasksClient.ListQueuesPagedResponselistQueues(LocationNameparent)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
LocationNameparent=LocationName.of("[PROJECT]","[LOCATION]");
for(Queueelement:cloudTasksClient.listQueues(parent).iterateAll()){
// doThingsWith(element);
}
}

publicfinalCloudTasksClient.ListQueuesPagedResponselistQueues(Stringparent)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringparent=LocationName.of("[PROJECT]","[LOCATION]").toString();
for(Queueelement:cloudTasksClient.listQueues(parent).iterateAll()){
// doThingsWith(element);
}
}

publicfinalUnaryCallable<ListQueuesRequest,ListQueuesResponse>listQueuesCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
ListQueuesRequestrequest=
ListQueuesRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setFilter("filter-1274492040")
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setReadMask(FieldMask.newBuilder().build())
.build();
while(true){
ListQueuesResponseresponse=cloudTasksClient.listQueuesCallable().call(request);
for(Queueelement:response.getResponsesList()){
// doThingsWith(element);
}
StringnextPageToken=response.getNextPageToken();
if(!Strings.isNullOrEmpty(nextPageToken)){
request=request.toBuilder().setPageToken(nextPageToken).build();
}else{
break;
}
}
}

publicfinalUnaryCallable<ListQueuesRequest,CloudTasksClient.ListQueuesPagedResponse>listQueuesPagedCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
ListQueuesRequestrequest=
ListQueuesRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setFilter("filter-1274492040")
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setReadMask(FieldMask.newBuilder().build())
.build();
ApiFuture<Queue>future=cloudTasksClient.listQueuesPagedCallable().futureCall(request);
// Do something.
for(Queueelement:future.get().iterateAll()){
// doThingsWith(element);
}
}

publicfinalCloudTasksClient.ListTasksPagedResponselistTasks(ListTasksRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
ListTasksRequestrequest=
ListTasksRequest.newBuilder()
.setParent(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
for(Taskelement:cloudTasksClient.listTasks(request).iterateAll()){
// doThingsWith(element);
}
}

publicfinalCloudTasksClient.ListTasksPagedResponselistTasks(QueueNameparent)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
QueueNameparent=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]");
for(Taskelement:cloudTasksClient.listTasks(parent).iterateAll()){
// doThingsWith(element);
}
}

publicfinalCloudTasksClient.ListTasksPagedResponselistTasks(Stringparent)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringparent=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString();
for(Taskelement:cloudTasksClient.listTasks(parent).iterateAll()){
// doThingsWith(element);
}
}

publicfinalUnaryCallable<ListTasksRequest,ListTasksResponse>listTasksCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
ListTasksRequestrequest=
ListTasksRequest.newBuilder()
.setParent(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
while(true){
ListTasksResponseresponse=cloudTasksClient.listTasksCallable().call(request);
for(Taskelement:response.getResponsesList()){
// doThingsWith(element);
}
StringnextPageToken=response.getNextPageToken();
if(!Strings.isNullOrEmpty(nextPageToken)){
request=request.toBuilder().setPageToken(nextPageToken).build();
}else{
break;
}
}
}

publicfinalUnaryCallable<ListTasksRequest,CloudTasksClient.ListTasksPagedResponse>listTasksPagedCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
ListTasksRequestrequest=
ListTasksRequest.newBuilder()
.setParent(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
ApiFuture<Task>future=cloudTasksClient.listTasksPagedCallable().futureCall(request);
// Do something.
for(Taskelement:future.get().iterateAll()){
// doThingsWith(element);
}
}

publicfinalQueuepauseQueue(PauseQueueRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
PauseQueueRequestrequest=
PauseQueueRequest.newBuilder()
.setName(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.build();
Queueresponse=cloudTasksClient.pauseQueue(request);
}

publicfinalQueuepauseQueue(QueueNamename)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
QueueNamename=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]");
Queueresponse=cloudTasksClient.pauseQueue(name);
}

publicfinalQueuepauseQueue(Stringname)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringname=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString();
Queueresponse=cloudTasksClient.pauseQueue(name);
}

publicfinalUnaryCallable<PauseQueueRequest,Queue>pauseQueueCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
PauseQueueRequestrequest=
PauseQueueRequest.newBuilder()
.setName(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.build();
ApiFuture<Queue>future=cloudTasksClient.pauseQueueCallable().futureCall(request);
// Do something.
Queueresponse=future.get();
}

publicfinalQueuepurgeQueue(PurgeQueueRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
PurgeQueueRequestrequest=
PurgeQueueRequest.newBuilder()
.setName(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.build();
Queueresponse=cloudTasksClient.purgeQueue(request);
}

publicfinalQueuepurgeQueue(QueueNamename)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
QueueNamename=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]");
Queueresponse=cloudTasksClient.purgeQueue(name);
}

publicfinalQueuepurgeQueue(Stringname)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringname=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString();
Queueresponse=cloudTasksClient.purgeQueue(name);
}

publicfinalUnaryCallable<PurgeQueueRequest,Queue>purgeQueueCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
PurgeQueueRequestrequest=
PurgeQueueRequest.newBuilder()
.setName(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.build();
ApiFuture<Queue>future=cloudTasksClient.purgeQueueCallable().futureCall(request);
// Do something.
Queueresponse=future.get();
}

publicfinalTaskrenewLease(RenewLeaseRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
RenewLeaseRequestrequest=
RenewLeaseRequest.newBuilder()
.setName(TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString())
.setScheduleTime(Timestamp.newBuilder().build())
.setLeaseDuration(Duration.newBuilder().build())
.build();
Taskresponse=cloudTasksClient.renewLease(request);
}

publicfinalTaskrenewLease(TaskNamename,TimestampscheduleTime,DurationleaseDuration)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
TaskNamename=TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]");
TimestampscheduleTime=Timestamp.newBuilder().build();
DurationleaseDuration=Duration.newBuilder().build();
Taskresponse=cloudTasksClient.renewLease(name,scheduleTime,leaseDuration);
}

publicfinalTaskrenewLease(Stringname,TimestampscheduleTime,DurationleaseDuration)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringname=TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString();
TimestampscheduleTime=Timestamp.newBuilder().build();
DurationleaseDuration=Duration.newBuilder().build();
Taskresponse=cloudTasksClient.renewLease(name,scheduleTime,leaseDuration);
}

publicfinalUnaryCallable<RenewLeaseRequest,Task>renewLeaseCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
RenewLeaseRequestrequest=
RenewLeaseRequest.newBuilder()
.setName(TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString())
.setScheduleTime(Timestamp.newBuilder().build())
.setLeaseDuration(Duration.newBuilder().build())
.build();
ApiFuture<Task>future=cloudTasksClient.renewLeaseCallable().futureCall(request);
// Do something.
Taskresponse=future.get();
}

publicfinalQueueresumeQueue(QueueNamename)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
QueueNamename=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]");
Queueresponse=cloudTasksClient.resumeQueue(name);
}

publicfinalQueueresumeQueue(ResumeQueueRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
ResumeQueueRequestrequest=
ResumeQueueRequest.newBuilder()
.setName(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.build();
Queueresponse=cloudTasksClient.resumeQueue(request);
}

publicfinalQueueresumeQueue(Stringname)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringname=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString();
Queueresponse=cloudTasksClient.resumeQueue(name);
}

publicfinalUnaryCallable<ResumeQueueRequest,Queue>resumeQueueCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
ResumeQueueRequestrequest=
ResumeQueueRequest.newBuilder()
.setName(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.build();
ApiFuture<Queue>future=cloudTasksClient.resumeQueueCallable().futureCall(request);
// Do something.
Queueresponse=future.get();
}

publicfinalTaskrunTask(RunTaskRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
RunTaskRequestrequest=
RunTaskRequest.newBuilder()
.setName(TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString())
.build();
Taskresponse=cloudTasksClient.runTask(request);
}

publicfinalTaskrunTask(TaskNamename)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
TaskNamename=TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]");
Taskresponse=cloudTasksClient.runTask(name);
}

publicfinalTaskrunTask(Stringname)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringname=TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString();
Taskresponse=cloudTasksClient.runTask(name);
}

publicfinalUnaryCallable<RunTaskRequest,Task>runTaskCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
RunTaskRequestrequest=
RunTaskRequest.newBuilder()
.setName(TaskName.of("[PROJECT]","[LOCATION]","[QUEUE]","[TASK]").toString())
.build();
ApiFuture<Task>future=cloudTasksClient.runTaskCallable().futureCall(request);
// Do something.
Taskresponse=future.get();
}

publicfinalPolicysetIamPolicy(ResourceNameresource,Policypolicy)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
ResourceNameresource=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]");
Policypolicy=Policy.newBuilder().build();
Policyresponse=cloudTasksClient.setIamPolicy(resource,policy);
}

publicfinalPolicysetIamPolicy(QueueNamequeue,Policypolicy)

publicfinalPolicysetIamPolicy(SetIamPolicyRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
SetIamPolicyRequestrequest=
SetIamPolicyRequest.newBuilder()
.setResource(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.setPolicy(Policy.newBuilder().build())
.setUpdateMask(FieldMask.newBuilder().build())
.build();
Policyresponse=cloudTasksClient.setIamPolicy(request);
}

publicfinalPolicysetIamPolicy(Stringresource,Policypolicy)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringresource=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString();
Policypolicy=Policy.newBuilder().build();
Policyresponse=cloudTasksClient.setIamPolicy(resource,policy);
}

publicfinalUnaryCallable<SetIamPolicyRequest,Policy>setIamPolicyCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
SetIamPolicyRequestrequest=
SetIamPolicyRequest.newBuilder()
.setResource(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.setPolicy(Policy.newBuilder().build())
.setUpdateMask(FieldMask.newBuilder().build())
.build();
ApiFuture<Policy>future=cloudTasksClient.setIamPolicyCallable().futureCall(request);
// Do something.
Policyresponse=future.get();
}

publicvoidshutdown()

publicvoidshutdownNow()

publicfinalTestIamPermissionsResponsetestIamPermissions(ResourceNameresource,List<String>permissions)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
ResourceNameresource=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]");
List<String>permissions=newArrayList<>();
TestIamPermissionsResponseresponse=
cloudTasksClient.testIamPermissions(resource,permissions);
}

publicfinalTestIamPermissionsResponsetestIamPermissions(QueueNamequeue,List<String>permissions)

publicfinalTestIamPermissionsResponsetestIamPermissions(TestIamPermissionsRequestrequest)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
TestIamPermissionsRequestrequest=
TestIamPermissionsRequest.newBuilder()
.setResource(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.addAllPermissions(newArrayList<String>())
.build();
TestIamPermissionsResponseresponse=cloudTasksClient.testIamPermissions(request);
}

publicfinalTestIamPermissionsResponsetestIamPermissions(Stringresource,List<String>permissions)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Stringresource=QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString();
List<String>permissions=newArrayList<>();
TestIamPermissionsResponseresponse=
cloudTasksClient.testIamPermissions(resource,permissions);
}

publicfinalUnaryCallable<TestIamPermissionsRequest,TestIamPermissionsResponse>testIamPermissionsCallable()

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
TestIamPermissionsRequestrequest=
TestIamPermissionsRequest.newBuilder()
.setResource(QueueName.of("[PROJECT]","[LOCATION]","[QUEUE]").toString())
.addAllPermissions(newArrayList<String>())
.build();
ApiFuture<TestIamPermissionsResponse>future=
cloudTasksClient.testIamPermissionsCallable().futureCall(request);
// Do something.
TestIamPermissionsResponseresponse=future.get();
}

publicfinalQueueupdateQueue(Queuequeue,FieldMaskupdateMask)

// This snippet has been automatically generated for illustrative purposes only.
// It may require modifications to work in your environment.
try(CloudTasksClientcloudTasksClient=CloudTasksClient.create()){
Queuequeue=Queue.newBuilder().build();
FieldMaskupdateMask=FieldMask.newBuilder().build();
Queueresponse=cloudTasksClient.updateQueue(queue,updateMask);
}