private static final TypeRegistry typeRegistry = TypeRegistry.newBuilder().build();

private static final ApiMethodDescriptor<CreateSchemaRequest, Schema>

createSchemaMethodDescriptor =

ApiMethodDescriptor.<CreateSchemaRequest, Schema>newBuilder()

.setFullMethodName("google.pubsub.v1.SchemaService/CreateSchema")

.setHttpMethod("POST")

.setType(ApiMethodDescriptor.MethodType.UNARY)

.setRequestFormatter(

ProtoMessageRequestFormatter.<CreateSchemaRequest>newBuilder()

.setPath(

"/v1/{parent=projects/*}/schemas",

request -> {

Map<String, String> fields = new HashMap<>();

ProtoRestSerializer<CreateSchemaRequest> serializer =

ProtoRestSerializer.create();

serializer.putPathParam(fields, "parent", request.getParent());

return fields;

})

.setQueryParamsExtractor(

request -> {

Map<String, List<String>> fields = new HashMap<>();

ProtoRestSerializer<CreateSchemaRequest> serializer =

ProtoRestSerializer.create();

serializer.putQueryParam(fields, "schemaId", request.getSchemaId());

serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");

return fields;

})

.setRequestBodyExtractor(

request ->

ProtoRestSerializer.create()

.toBody("schema", request.getSchema(), true))

.build())

.setResponseParser(

ProtoMessageResponseParser.<Schema>newBuilder()

.setDefaultInstance(Schema.getDefaultInstance())

.setDefaultTypeRegistry(typeRegistry)

.build())

.build();

private static final ApiMethodDescriptor<GetSchemaRequest, Schema> getSchemaMethodDescriptor =

ApiMethodDescriptor.<GetSchemaRequest, Schema>newBuilder()

.setFullMethodName("google.pubsub.v1.SchemaService/GetSchema")

.setHttpMethod("GET")

.setType(ApiMethodDescriptor.MethodType.UNARY)

.setRequestFormatter(

ProtoMessageRequestFormatter.<GetSchemaRequest>newBuilder()

.setPath(

"/v1/{name=projects/*/schemas/*}",

request -> {

Map<String, String> fields = new HashMap<>();

ProtoRestSerializer<GetSchemaRequest> serializer =

ProtoRestSerializer.create();

serializer.putPathParam(fields, "name", request.getName());

return fields;

})

.setQueryParamsExtractor(

request -> {

Map<String, List<String>> fields = new HashMap<>();

ProtoRestSerializer<GetSchemaRequest> serializer =

ProtoRestSerializer.create();

serializer.putQueryParam(fields, "view", request.getViewValue());

serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");

return fields;

})

.setRequestBodyExtractor(request -> null)

.build())

.setResponseParser(

ProtoMessageResponseParser.<Schema>newBuilder()

.setDefaultInstance(Schema.getDefaultInstance())

.setDefaultTypeRegistry(typeRegistry)

.build())

.build();

private static final ApiMethodDescriptor<ListSchemasRequest, ListSchemasResponse>

listSchemasMethodDescriptor =

ApiMethodDescriptor.<ListSchemasRequest, ListSchemasResponse>newBuilder()

.setFullMethodName("google.pubsub.v1.SchemaService/ListSchemas")

.setHttpMethod("GET")

.setType(ApiMethodDescriptor.MethodType.UNARY)

.setRequestFormatter(

ProtoMessageRequestFormatter.<ListSchemasRequest>newBuilder()

.setPath(

"/v1/{parent=projects/*}/schemas",

request -> {

Map<String, String> fields = new HashMap<>();

ProtoRestSerializer<ListSchemasRequest> serializer =

ProtoRestSerializer.create();

serializer.putPathParam(fields, "parent", request.getParent());

return fields;

})

.setQueryParamsExtractor(

request -> {

Map<String, List<String>> fields = new HashMap<>();

ProtoRestSerializer<ListSchemasRequest> serializer =

ProtoRestSerializer.create();

serializer.putQueryParam(fields, "pageSize", request.getPageSize());

serializer.putQueryParam(fields, "pageToken", request.getPageToken());

serializer.putQueryParam(fields, "view", request.getViewValue());

serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");

return fields;

})

.setRequestBodyExtractor(request -> null)

.build())

.setResponseParser(

ProtoMessageResponseParser.<ListSchemasResponse>newBuilder()

.setDefaultInstance(ListSchemasResponse.getDefaultInstance())

.setDefaultTypeRegistry(typeRegistry)

.build())

.build();

private static final ApiMethodDescriptor<ListSchemaRevisionsRequest, ListSchemaRevisionsResponse>

listSchemaRevisionsMethodDescriptor =

ApiMethodDescriptor.<ListSchemaRevisionsRequest, ListSchemaRevisionsResponse>newBuilder()

.setFullMethodName("google.pubsub.v1.SchemaService/ListSchemaRevisions")

.setHttpMethod("GET")

.setType(ApiMethodDescriptor.MethodType.UNARY)

.setRequestFormatter(

ProtoMessageRequestFormatter.<ListSchemaRevisionsRequest>newBuilder()

.setPath(

"/v1/{name=projects/*/schemas/*}:listRevisions",

request -> {

Map<String, String> fields = new HashMap<>();

ProtoRestSerializer<ListSchemaRevisionsRequest> serializer =

ProtoRestSerializer.create();

serializer.putPathParam(fields, "name", request.getName());

return fields;

})

.setQueryParamsExtractor(

request -> {

Map<String, List<String>> fields = new HashMap<>();

ProtoRestSerializer<ListSchemaRevisionsRequest> serializer =

ProtoRestSerializer.create();

serializer.putQueryParam(fields, "pageSize", request.getPageSize());

serializer.putQueryParam(fields, "pageToken", request.getPageToken());

serializer.putQueryParam(fields, "view", request.getViewValue());

serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");

return fields;

})

.setRequestBodyExtractor(request -> null)

.build())

.setResponseParser(

ProtoMessageResponseParser.<ListSchemaRevisionsResponse>newBuilder()

.setDefaultInstance(ListSchemaRevisionsResponse.getDefaultInstance())

.setDefaultTypeRegistry(typeRegistry)

.build())

.build();

private static final ApiMethodDescriptor<CommitSchemaRequest, Schema>

commitSchemaMethodDescriptor =

ApiMethodDescriptor.<CommitSchemaRequest, Schema>newBuilder()

.setFullMethodName("google.pubsub.v1.SchemaService/CommitSchema")

.setHttpMethod("POST")

.setType(ApiMethodDescriptor.MethodType.UNARY)

.setRequestFormatter(

ProtoMessageRequestFormatter.<CommitSchemaRequest>newBuilder()

.setPath(

"/v1/{name=projects/*/schemas/*}:commit",

request -> {

Map<String, String> fields = new HashMap<>();

ProtoRestSerializer<CommitSchemaRequest> serializer =

ProtoRestSerializer.create();

serializer.putPathParam(fields, "name", request.getName());

return fields;

})

.setQueryParamsExtractor(

request -> {

Map<String, List<String>> fields = new HashMap<>();

ProtoRestSerializer<CommitSchemaRequest> serializer =

ProtoRestSerializer.create();

serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");

return fields;

})

.setRequestBodyExtractor(

request ->

ProtoRestSerializer.create()

.toBody("*", request.toBuilder().clearName().build(), true))

.build())

.setResponseParser(

ProtoMessageResponseParser.<Schema>newBuilder()

.setDefaultInstance(Schema.getDefaultInstance())

.setDefaultTypeRegistry(typeRegistry)

.build())

.build();

private static final ApiMethodDescriptor<RollbackSchemaRequest, Schema>

rollbackSchemaMethodDescriptor =

ApiMethodDescriptor.<RollbackSchemaRequest, Schema>newBuilder()

.setFullMethodName("google.pubsub.v1.SchemaService/RollbackSchema")

.setHttpMethod("POST")

.setType(ApiMethodDescriptor.MethodType.UNARY)

.setRequestFormatter(

ProtoMessageRequestFormatter.<RollbackSchemaRequest>newBuilder()

.setPath(

"/v1/{name=projects/*/schemas/*}:rollback",

request -> {

Map<String, String> fields = new HashMap<>();

ProtoRestSerializer<RollbackSchemaRequest> serializer =

ProtoRestSerializer.create();

serializer.putPathParam(fields, "name", request.getName());

return fields;

})

.setQueryParamsExtractor(

request -> {

Map<String, List<String>> fields = new HashMap<>();

ProtoRestSerializer<RollbackSchemaRequest> serializer =

ProtoRestSerializer.create();

serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");

return fields;

})

.setRequestBodyExtractor(

request ->

ProtoRestSerializer.create()

.toBody("*", request.toBuilder().clearName().build(), true))

.build())

.setResponseParser(

ProtoMessageResponseParser.<Schema>newBuilder()

.setDefaultInstance(Schema.getDefaultInstance())

.setDefaultTypeRegistry(typeRegistry)

.build())

.build();

private static final ApiMethodDescriptor<DeleteSchemaRevisionRequest, Schema>

deleteSchemaRevisionMethodDescriptor =

ApiMethodDescriptor.<DeleteSchemaRevisionRequest, Schema>newBuilder()

.setFullMethodName("google.pubsub.v1.SchemaService/DeleteSchemaRevision")

.setHttpMethod("DELETE")

.setType(ApiMethodDescriptor.MethodType.UNARY)

.setRequestFormatter(

ProtoMessageRequestFormatter.<DeleteSchemaRevisionRequest>newBuilder()

.setPath(

"/v1/{name=projects/*/schemas/*}:deleteRevision",

request -> {

Map<String, String> fields = new HashMap<>();

ProtoRestSerializer<DeleteSchemaRevisionRequest> serializer =

ProtoRestSerializer.create();

serializer.putPathParam(fields, "name", request.getName());

return fields;

})

.setQueryParamsExtractor(

request -> {

Map<String, List<String>> fields = new HashMap<>();

ProtoRestSerializer<DeleteSchemaRevisionRequest> serializer =

ProtoRestSerializer.create();

serializer.putQueryParam(fields, "revisionId", request.getRevisionId());

serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");

return fields;

})

.setRequestBodyExtractor(request -> null)

.build())

.setResponseParser(

ProtoMessageResponseParser.<Schema>newBuilder()

.setDefaultInstance(Schema.getDefaultInstance())

.setDefaultTypeRegistry(typeRegistry)

.build())

.build();

private static final ApiMethodDescriptor<DeleteSchemaRequest, Empty>

deleteSchemaMethodDescriptor =

ApiMethodDescriptor.<DeleteSchemaRequest, Empty>newBuilder()

.setFullMethodName("google.pubsub.v1.SchemaService/DeleteSchema")

.setHttpMethod("DELETE")

.setType(ApiMethodDescriptor.MethodType.UNARY)

.setRequestFormatter(

ProtoMessageRequestFormatter.<DeleteSchemaRequest>newBuilder()

.setPath(

"/v1/{name=projects/*/schemas/*}",

request -> {

Map<String, String> fields = new HashMap<>();

ProtoRestSerializer<DeleteSchemaRequest> serializer =

ProtoRestSerializer.create();

serializer.putPathParam(fields, "name", request.getName());

return fields;

})

.setQueryParamsExtractor(

request -> {

Map<String, List<String>> fields = new HashMap<>();

ProtoRestSerializer<DeleteSchemaRequest> serializer =

ProtoRestSerializer.create();

serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");

return fields;

})

.setRequestBodyExtractor(request -> null)

.build())

.setResponseParser(

ProtoMessageResponseParser.<Empty>newBuilder()

.setDefaultInstance(Empty.getDefaultInstance())

.setDefaultTypeRegistry(typeRegistry)

.build())

.build();

private static final ApiMethodDescriptor<ValidateSchemaRequest, ValidateSchemaResponse>

validateSchemaMethodDescriptor =

ApiMethodDescriptor.<ValidateSchemaRequest, ValidateSchemaResponse>newBuilder()

.setFullMethodName("google.pubsub.v1.SchemaService/ValidateSchema")

.setHttpMethod("POST")

.setType(ApiMethodDescriptor.MethodType.UNARY)

.setRequestFormatter(

ProtoMessageRequestFormatter.<ValidateSchemaRequest>newBuilder()

.setPath(

"/v1/{parent=projects/*}/schemas:validate",

request -> {

Map<String, String> fields = new HashMap<>();

ProtoRestSerializer<ValidateSchemaRequest> serializer =

ProtoRestSerializer.create();

serializer.putPathParam(fields, "parent", request.getParent());

return fields;

})

.setQueryParamsExtractor(

request -> {

Map<String, List<String>> fields = new HashMap<>();

ProtoRestSerializer<ValidateSchemaRequest> serializer =

ProtoRestSerializer.create();

serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");

return fields;

})

.setRequestBodyExtractor(

request ->

ProtoRestSerializer.create()

.toBody("*", request.toBuilder().clearParent().build(), true))

.build())

.setResponseParser(

ProtoMessageResponseParser.<ValidateSchemaResponse>newBuilder()

.setDefaultInstance(ValidateSchemaResponse.getDefaultInstance())

.setDefaultTypeRegistry(typeRegistry)

.build())

.build();

private static final ApiMethodDescriptor<ValidateMessageRequest, ValidateMessageResponse>

validateMessageMethodDescriptor =

ApiMethodDescriptor.<ValidateMessageRequest, ValidateMessageResponse>newBuilder()

.setFullMethodName("google.pubsub.v1.SchemaService/ValidateMessage")

.setHttpMethod("POST")

.setType(ApiMethodDescriptor.MethodType.UNARY)

.setRequestFormatter(

ProtoMessageRequestFormatter.<ValidateMessageRequest>newBuilder()

.setPath(

"/v1/{parent=projects/*}/schemas:validateMessage",

request -> {

Map<String, String> fields = new HashMap<>();

ProtoRestSerializer<ValidateMessageRequest> serializer =

ProtoRestSerializer.create();

serializer.putPathParam(fields, "parent", request.getParent());

return fields;

})

.setQueryParamsExtractor(

request -> {

Map<String, List<String>> fields = new HashMap<>();

ProtoRestSerializer<ValidateMessageRequest> serializer =

ProtoRestSerializer.create();

serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");

return fields;

})

.setRequestBodyExtractor(

request ->

ProtoRestSerializer.create()

.toBody("*", request.toBuilder().clearParent().build(), true))

.build())

.setResponseParser(

ProtoMessageResponseParser.<ValidateMessageResponse>newBuilder()

.setDefaultInstance(ValidateMessageResponse.getDefaultInstance())

.setDefaultTypeRegistry(typeRegistry)

.build())

.build();

private static final ApiMethodDescriptor<SetIamPolicyRequest, Policy>

setIamPolicyMethodDescriptor =

ApiMethodDescriptor.<SetIamPolicyRequest, Policy>newBuilder()

.setFullMethodName("google.iam.v1.IAMPolicy/SetIamPolicy")

.setHttpMethod("POST")

.setType(ApiMethodDescriptor.MethodType.UNARY)

.setRequestFormatter(

ProtoMessageRequestFormatter.<SetIamPolicyRequest>newBuilder()

.setPath(

"/v1/{resource=projects/*/topics/*}:setIamPolicy",

request -> {

Map<String, String> fields = new HashMap<>();

ProtoRestSerializer<SetIamPolicyRequest> serializer =

ProtoRestSerializer.create();

serializer.putPathParam(fields, "resource", request.getResource());

return fields;

})

.setAdditionalPaths(

"/v1/{resource=projects/*/subscriptions/*}:setIamPolicy",

"/v1/{resource=projects/*/snapshots/*}:setIamPolicy",

"/v1/{resource=projects/*/schemas/*}:setIamPolicy")

.setQueryParamsExtractor(

request -> {

Map<String, List<String>> fields = new HashMap<>();

ProtoRestSerializer<SetIamPolicyRequest> serializer =

ProtoRestSerializer.create();

serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");

return fields;

})

.setRequestBodyExtractor(

request ->

ProtoRestSerializer.create()

.toBody("*", request.toBuilder().clearResource().build(), true))

.build())

.setResponseParser(

ProtoMessageResponseParser.<Policy>newBuilder()

.setDefaultInstance(Policy.getDefaultInstance())

.setDefaultTypeRegistry(typeRegistry)

.build())

.build();

private static final ApiMethodDescriptor<GetIamPolicyRequest, Policy>

getIamPolicyMethodDescriptor =

ApiMethodDescriptor.<GetIamPolicyRequest, Policy>newBuilder()

.setFullMethodName("google.iam.v1.IAMPolicy/GetIamPolicy")

.setHttpMethod("GET")

.setType(ApiMethodDescriptor.MethodType.UNARY)

.setRequestFormatter(

ProtoMessageRequestFormatter.<GetIamPolicyRequest>newBuilder()

.setPath(

"/v1/{resource=projects/*/topics/*}:getIamPolicy",

request -> {

Map<String, String> fields = new HashMap<>();

ProtoRestSerializer<GetIamPolicyRequest> serializer =

ProtoRestSerializer.create();

serializer.putPathParam(fields, "resource", request.getResource());

return fields;

})

.setAdditionalPaths(

"/v1/{resource=projects/*/subscriptions/*}:getIamPolicy",

"/v1/{resource=projects/*/snapshots/*}:getIamPolicy",

"/v1/{resource=projects/*/schemas/*}:getIamPolicy")

.setQueryParamsExtractor(

request -> {

Map<String, List<String>> fields = new HashMap<>();

ProtoRestSerializer<GetIamPolicyRequest> serializer =

ProtoRestSerializer.create();

serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");

return fields;

})

.setRequestBodyExtractor(request -> null)

.build())

.setResponseParser(

ProtoMessageResponseParser.<Policy>newBuilder()

.setDefaultInstance(Policy.getDefaultInstance())

.setDefaultTypeRegistry(typeRegistry)

.build())

.build();

private static final ApiMethodDescriptor<TestIamPermissionsRequest, TestIamPermissionsResponse>

testIamPermissionsMethodDescriptor =

ApiMethodDescriptor.<TestIamPermissionsRequest, TestIamPermissionsResponse>newBuilder()

.setFullMethodName("google.iam.v1.IAMPolicy/TestIamPermissions")

.setHttpMethod("POST")

.setType(ApiMethodDescriptor.MethodType.UNARY)

.setRequestFormatter(

ProtoMessageRequestFormatter.<TestIamPermissionsRequest>newBuilder()

.setPath(

"/v1/{resource=projects/*/subscriptions/*}:testIamPermissions",

request -> {

Map<String, String> fields = new HashMap<>();

ProtoRestSerializer<TestIamPermissionsRequest> serializer =

ProtoRestSerializer.create();

serializer.putPathParam(fields, "resource", request.getResource());

return fields;

})

.setAdditionalPaths(

"/v1/{resource=projects/*/topics/*}:testIamPermissions",

"/v1/{resource=projects/*/snapshots/*}:testIamPermissions",

"/v1/{resource=projects/*/schemas/*}:testIamPermissions")

.setQueryParamsExtractor(

request -> {

Map<String, List<String>> fields = new HashMap<>();

ProtoRestSerializer<TestIamPermissionsRequest> serializer =

ProtoRestSerializer.create();

serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");

return fields;

})

.setRequestBodyExtractor(

request ->

ProtoRestSerializer.create()

.toBody("*", request.toBuilder().clearResource().build(), true))

.build())

.setResponseParser(

ProtoMessageResponseParser.<TestIamPermissionsResponse>newBuilder()

.setDefaultInstance(TestIamPermissionsResponse.getDefaultInstance())

.setDefaultTypeRegistry(typeRegistry)

.build())

.build();

private final UnaryCallable<CreateSchemaRequest, Schema> createSchemaCallable;

private final UnaryCallable<GetSchemaRequest, Schema> getSchemaCallable;

private final UnaryCallable<ListSchemasRequest, ListSchemasResponse> listSchemasCallable;

private final UnaryCallable<ListSchemasRequest, ListSchemasPagedResponse>

listSchemasPagedCallable;

private final UnaryCallable<ListSchemaRevisionsRequest, ListSchemaRevisionsResponse>

listSchemaRevisionsCallable;

private final UnaryCallable<ListSchemaRevisionsRequest, ListSchemaRevisionsPagedResponse>

listSchemaRevisionsPagedCallable;

private final UnaryCallable<CommitSchemaRequest, Schema> commitSchemaCallable;

private final UnaryCallable<RollbackSchemaRequest, Schema> rollbackSchemaCallable;

private final UnaryCallable<DeleteSchemaRevisionRequest, Schema> deleteSchemaRevisionCallable;

private final UnaryCallable<DeleteSchemaRequest, Empty> deleteSchemaCallable;

private final UnaryCallable<ValidateSchemaRequest, ValidateSchemaResponse> validateSchemaCallable;

private final UnaryCallable<ValidateMessageRequest, ValidateMessageResponse>

validateMessageCallable;

private final UnaryCallable<SetIamPolicyRequest, Policy> setIamPolicyCallable;

private final UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable;

private final UnaryCallable<TestIamPermissionsRequest, TestIamPermissionsResponse>

testIamPermissionsCallable;

private final BackgroundResource backgroundResources;

private final HttpJsonStubCallableFactory callableFactory;

public static final HttpJsonSchemaServiceStub create(SchemaServiceStubSettings settings)

throws IOException {

return new HttpJsonSchemaServiceStub(settings, ClientContext.create(settings));

}

public static final HttpJsonSchemaServiceStub create(ClientContext clientContext)

throws IOException {

return new HttpJsonSchemaServiceStub(

SchemaServiceStubSettings.newHttpJsonBuilder().build(), clientContext);

}

public static final HttpJsonSchemaServiceStub create(

ClientContext clientContext, HttpJsonStubCallableFactory callableFactory) throws IOException {

return new HttpJsonSchemaServiceStub(

SchemaServiceStubSettings.newHttpJsonBuilder().build(), clientContext, callableFactory);

}

/**

* Constructs an instance of HttpJsonSchemaServiceStub, using the given settings. This is

* protected so that it is easy to make a subclass, but otherwise, the static factory methods

* should be preferred.

*/

protected HttpJsonSchemaServiceStub(

SchemaServiceStubSettings settings, ClientContext clientContext) throws IOException {

this(settings, clientContext, new HttpJsonSchemaServiceCallableFactory());

}

/**

* Constructs an instance of HttpJsonSchemaServiceStub, using the given settings. This is

* protected so that it is easy to make a subclass, but otherwise, the static factory methods

* should be preferred.

*/

protected HttpJsonSchemaServiceStub(

SchemaServiceStubSettings settings,

ClientContext clientContext,

HttpJsonStubCallableFactory callableFactory)

throws IOException {

this.callableFactory = callableFactory;

HttpJsonCallSettings<CreateSchemaRequest, Schema> createSchemaTransportSettings =

HttpJsonCallSettings.<CreateSchemaRequest, Schema>newBuilder()

.setMethodDescriptor(createSchemaMethodDescriptor)

.setTypeRegistry(typeRegistry)

.setParamsExtractor(

request -> {

RequestParamsBuilder builder = RequestParamsBuilder.create();

builder.add("parent", String.valueOf(request.getParent()));

return builder.build();

})

.build();

HttpJsonCallSettings<GetSchemaRequest, Schema> getSchemaTransportSettings =

HttpJsonCallSettings.<GetSchemaRequest, Schema>newBuilder()

.setMethodDescriptor(getSchemaMethodDescriptor)

.setTypeRegistry(typeRegistry)

.setParamsExtractor(

request -> {

RequestParamsBuilder builder = RequestParamsBuilder.create();

builder.add("name", String.valueOf(request.getName()));

return builder.build();

})

.build();

HttpJsonCallSettings<ListSchemasRequest, ListSchemasResponse> listSchemasTransportSettings =

HttpJsonCallSettings.<ListSchemasRequest, ListSchemasResponse>newBuilder()

.setMethodDescriptor(listSchemasMethodDescriptor)

.setTypeRegistry(typeRegistry)

.setParamsExtractor(

request -> {

RequestParamsBuilder builder = RequestParamsBuilder.create();

builder.add("parent", String.valueOf(request.getParent()));

return builder.build();

})

.build();

HttpJsonCallSettings<ListSchemaRevisionsRequest, ListSchemaRevisionsResponse>

listSchemaRevisionsTransportSettings =

HttpJsonCallSettings

.<ListSchemaRevisionsRequest, ListSchemaRevisionsResponse>newBuilder()

.setMethodDescriptor(listSchemaRevisionsMethodDescriptor)

.setTypeRegistry(typeRegistry)

.setParamsExtractor(

request -> {

RequestParamsBuilder builder = RequestParamsBuilder.create();

builder.add("name", String.valueOf(request.getName()));

return builder.build();

})

.build();

HttpJsonCallSettings<CommitSchemaRequest, Schema> commitSchemaTransportSettings =

HttpJsonCallSettings.<CommitSchemaRequest, Schema>newBuilder()

.setMethodDescriptor(commitSchemaMethodDescriptor)

.setTypeRegistry(typeRegistry)

.setParamsExtractor(

request -> {

RequestParamsBuilder builder = RequestParamsBuilder.create();

builder.add("name", String.valueOf(request.getName()));

return builder.build();

})

.build();

HttpJsonCallSettings<RollbackSchemaRequest, Schema> rollbackSchemaTransportSettings =

HttpJsonCallSettings.<RollbackSchemaRequest, Schema>newBuilder()

.setMethodDescriptor(rollbackSchemaMethodDescriptor)

.setTypeRegistry(typeRegistry)

.setParamsExtractor(

request -> {

RequestParamsBuilder builder = RequestParamsBuilder.create();

builder.add("name", String.valueOf(request.getName()));

return builder.build();

})

.build();

HttpJsonCallSettings<DeleteSchemaRevisionRequest, Schema>

deleteSchemaRevisionTransportSettings =

HttpJsonCallSettings.<DeleteSchemaRevisionRequest, Schema>newBuilder()

.setMethodDescriptor(deleteSchemaRevisionMethodDescriptor)

.setTypeRegistry(typeRegistry)

.setParamsExtractor(

request -> {

RequestParamsBuilder builder = RequestParamsBuilder.create();

builder.add("name", String.valueOf(request.getName()));

return builder.build();

})

.build();

HttpJsonCallSettings<DeleteSchemaRequest, Empty> deleteSchemaTransportSettings =

HttpJsonCallSettings.<DeleteSchemaRequest, Empty>newBuilder()

.setMethodDescriptor(deleteSchemaMethodDescriptor)

.setTypeRegistry(typeRegistry)

.setParamsExtractor(

request -> {

RequestParamsBuilder builder = RequestParamsBuilder.create();

builder.add("name", String.valueOf(request.getName()));

return builder.build();

})

.build();

HttpJsonCallSettings<ValidateSchemaRequest, ValidateSchemaResponse>

validateSchemaTransportSettings =

HttpJsonCallSettings.<ValidateSchemaRequest, ValidateSchemaResponse>newBuilder()

.setMethodDescriptor(validateSchemaMethodDescriptor)

.setTypeRegistry(typeRegistry)

.setParamsExtractor(

request -> {

RequestParamsBuilder builder = RequestParamsBuilder.create();

builder.add("parent", String.valueOf(request.getParent()));

return builder.build();

})

.build();

HttpJsonCallSettings<ValidateMessageRequest, ValidateMessageResponse>

validateMessageTransportSettings =

HttpJsonCallSettings.<ValidateMessageRequest, ValidateMessageResponse>newBuilder()

.setMethodDescriptor(validateMessageMethodDescriptor)

.setTypeRegistry(typeRegistry)

.setParamsExtractor(

request -> {

RequestParamsBuilder builder = RequestParamsBuilder.create();

builder.add("parent", String.valueOf(request.getParent()));

return builder.build();

})

.build();

HttpJsonCallSettings<SetIamPolicyRequest, Policy> setIamPolicyTransportSettings =

HttpJsonCallSettings.<SetIamPolicyRequest, Policy>newBuilder()

.setMethodDescriptor(setIamPolicyMethodDescriptor)

.setTypeRegistry(typeRegistry)

.setParamsExtractor(

request -> {

RequestParamsBuilder builder = RequestParamsBuilder.create();

builder.add("resource", String.valueOf(request.getResource()));

return builder.build();

})

.build();

HttpJsonCallSettings<GetIamPolicyRequest, Policy> getIamPolicyTransportSettings =

HttpJsonCallSettings.<GetIamPolicyRequest, Policy>newBuilder()

.setMethodDescriptor(getIamPolicyMethodDescriptor)

.setTypeRegistry(typeRegistry)

.setParamsExtractor(

request -> {

RequestParamsBuilder builder = RequestParamsBuilder.create();

builder.add("resource", String.valueOf(request.getResource()));

return builder.build();

})

.build();

HttpJsonCallSettings<TestIamPermissionsRequest, TestIamPermissionsResponse>

testIamPermissionsTransportSettings =

HttpJsonCallSettings.<TestIamPermissionsRequest, TestIamPermissionsResponse>newBuilder()

.setMethodDescriptor(testIamPermissionsMethodDescriptor)

.setTypeRegistry(typeRegistry)

.setParamsExtractor(

request -> {

RequestParamsBuilder builder = RequestParamsBuilder.create();

builder.add("resource", String.valueOf(request.getResource()));

return builder.build();

})

.build();

this.createSchemaCallable =

callableFactory.createUnaryCallable(

createSchemaTransportSettings, settings.createSchemaSettings(), clientContext);

this.getSchemaCallable =

callableFactory.createUnaryCallable(

getSchemaTransportSettings, settings.getSchemaSettings(), clientContext);

this.listSchemasCallable =

callableFactory.createUnaryCallable(

listSchemasTransportSettings, settings.listSchemasSettings(), clientContext);

this.listSchemasPagedCallable =

callableFactory.createPagedCallable(

listSchemasTransportSettings, settings.listSchemasSettings(), clientContext);

this.listSchemaRevisionsCallable =

callableFactory.createUnaryCallable(

listSchemaRevisionsTransportSettings,

settings.listSchemaRevisionsSettings(),

clientContext);

this.listSchemaRevisionsPagedCallable =

callableFactory.createPagedCallable(

listSchemaRevisionsTransportSettings,

settings.listSchemaRevisionsSettings(),

clientContext);

this.commitSchemaCallable =

callableFactory.createUnaryCallable(

commitSchemaTransportSettings, settings.commitSchemaSettings(), clientContext);

this.rollbackSchemaCallable =

callableFactory.createUnaryCallable(

rollbackSchemaTransportSettings, settings.rollbackSchemaSettings(), clientContext);

this.deleteSchemaRevisionCallable =

callableFactory.createUnaryCallable(

deleteSchemaRevisionTransportSettings,

settings.deleteSchemaRevisionSettings(),

clientContext);

this.deleteSchemaCallable =

callableFactory.createUnaryCallable(

deleteSchemaTransportSettings, settings.deleteSchemaSettings(), clientContext);

this.validateSchemaCallable =

callableFactory.createUnaryCallable(

validateSchemaTransportSettings, settings.validateSchemaSettings(), clientContext);

this.validateMessageCallable =

callableFactory.createUnaryCallable(

validateMessageTransportSettings, settings.validateMessageSettings(), clientContext);

this.setIamPolicyCallable =

callableFactory.createUnaryCallable(

setIamPolicyTransportSettings, settings.setIamPolicySettings(), clientContext);

this.getIamPolicyCallable =

callableFactory.createUnaryCallable(

getIamPolicyTransportSettings, settings.getIamPolicySettings(), clientContext);

this.testIamPermissionsCallable =

callableFactory.createUnaryCallable(

testIamPermissionsTransportSettings,

settings.testIamPermissionsSettings(),

clientContext);

this.backgroundResources =

new BackgroundResourceAggregation(clientContext.getBackgroundResources());

}

@InternalApi

public static List<ApiMethodDescriptor> getMethodDescriptors() {

List<ApiMethodDescriptor> methodDescriptors = new ArrayList<>();

methodDescriptors.add(createSchemaMethodDescriptor);

methodDescriptors.add(getSchemaMethodDescriptor);

methodDescriptors.add(listSchemasMethodDescriptor);

methodDescriptors.add(listSchemaRevisionsMethodDescriptor);

methodDescriptors.add(commitSchemaMethodDescriptor);

methodDescriptors.add(rollbackSchemaMethodDescriptor);

methodDescriptors.add(deleteSchemaRevisionMethodDescriptor);

methodDescriptors.add(deleteSchemaMethodDescriptor);

methodDescriptors.add(validateSchemaMethodDescriptor);

methodDescriptors.add(validateMessageMethodDescriptor);

methodDescriptors.add(setIamPolicyMethodDescriptor);

methodDescriptors.add(getIamPolicyMethodDescriptor);

methodDescriptors.add(testIamPermissionsMethodDescriptor);

return methodDescriptors;

}

@Override

public UnaryCallable<CreateSchemaRequest, Schema> createSchemaCallable() {

return createSchemaCallable;

}

@Override

public UnaryCallable<GetSchemaRequest, Schema> getSchemaCallable() {

return getSchemaCallable;

}

@Override

public UnaryCallable<ListSchemasRequest, ListSchemasResponse> listSchemasCallable() {

return listSchemasCallable;

}

@Override

public UnaryCallable<ListSchemasRequest, ListSchemasPagedResponse> listSchemasPagedCallable() {

return listSchemasPagedCallable;

}

@Override

public UnaryCallable<ListSchemaRevisionsRequest, ListSchemaRevisionsResponse>

listSchemaRevisionsCallable() {

return listSchemaRevisionsCallable;

}

@Override

public UnaryCallable<ListSchemaRevisionsRequest, ListSchemaRevisionsPagedResponse>

listSchemaRevisionsPagedCallable() {

return listSchemaRevisionsPagedCallable;

}

@Override

public UnaryCallable<CommitSchemaRequest, Schema> commitSchemaCallable() {

return commitSchemaCallable;

}

@Override

public UnaryCallable<RollbackSchemaRequest, Schema> rollbackSchemaCallable() {

return rollbackSchemaCallable;

}

@Override

public UnaryCallable<DeleteSchemaRevisionRequest, Schema> deleteSchemaRevisionCallable() {

return deleteSchemaRevisionCallable;

}

@Override

public UnaryCallable<DeleteSchemaRequest, Empty> deleteSchemaCallable() {

return deleteSchemaCallable;

}

@Override

public UnaryCallable<ValidateSchemaRequest, ValidateSchemaResponse> validateSchemaCallable() {

return validateSchemaCallable;

}

@Override

public UnaryCallable<ValidateMessageRequest, ValidateMessageResponse> validateMessageCallable() {

return validateMessageCallable;

}

@Override

public UnaryCallable<SetIamPolicyRequest, Policy> setIamPolicyCallable() {

return setIamPolicyCallable;

}

@Override

public UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable() {

return getIamPolicyCallable;

}

@Override

public UnaryCallable<TestIamPermissionsRequest, TestIamPermissionsResponse>

testIamPermissionsCallable() {

return testIamPermissionsCallable;

}

@Override

public final void close() {

try {

backgroundResources.close();

} catch (RuntimeException e) {

throw e;

} catch (Exception e) {

throw new IllegalStateException("Failed to close resource", e);

}

}

@Override

public void shutdown() {

backgroundResources.shutdown();

}

@Override

public boolean isShutdown() {

return backgroundResources.isShutdown();

}

@Override

public boolean isTerminated() {

return backgroundResources.isTerminated();

}

@Override

public void shutdownNow() {

backgroundResources.shutdownNow();

}

@Override

public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException {

return backgroundResources.awaitTermination(duration, unit);

}