- * Service for doing schema-related operations. - *- */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/pubsub/v1/schema.proto") -@io.grpc.stub.annotations.GrpcGenerated -public final class SchemaServiceGrpc { - - private SchemaServiceGrpc() {} - - public static final java.lang.String SERVICE_NAME = "google.pubsub.v1.SchemaService"; - - // Static method descriptors that strictly reflect the proto. - private static volatile io.grpc.MethodDescriptor< - com.google.pubsub.v1.CreateSchemaRequest, com.google.pubsub.v1.Schema> - getCreateSchemaMethod; - - @io.grpc.stub.annotations.RpcMethod( - fullMethodName = SERVICE_NAME + '/' + "CreateSchema", - requestType = com.google.pubsub.v1.CreateSchemaRequest.class, - responseType = com.google.pubsub.v1.Schema.class, - methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor< - com.google.pubsub.v1.CreateSchemaRequest, com.google.pubsub.v1.Schema> - getCreateSchemaMethod() { - io.grpc.MethodDescriptor
- * Service for doing schema-related operations. - *- */ - public interface AsyncService { - - /** - * - * - *
- * Creates a schema. - *- */ - default void createSchema( - com.google.pubsub.v1.CreateSchemaRequest request, - io.grpc.stub.StreamObserver
- * Gets a schema. - *- */ - default void getSchema( - com.google.pubsub.v1.GetSchemaRequest request, - io.grpc.stub.StreamObserver
- * Lists schemas in a project. - *- */ - default void listSchemas( - com.google.pubsub.v1.ListSchemasRequest request, - io.grpc.stub.StreamObserver
- * Lists all schema revisions for the named schema. - *- */ - default void listSchemaRevisions( - com.google.pubsub.v1.ListSchemaRevisionsRequest request, - io.grpc.stub.StreamObserver
- * Commits a new schema revision to an existing schema. - *- */ - default void commitSchema( - com.google.pubsub.v1.CommitSchemaRequest request, - io.grpc.stub.StreamObserver
- * Creates a new schema revision that is a copy of the provided revision_id. - *- */ - default void rollbackSchema( - com.google.pubsub.v1.RollbackSchemaRequest request, - io.grpc.stub.StreamObserver
- * Deletes a specific schema revision. - *- */ - default void deleteSchemaRevision( - com.google.pubsub.v1.DeleteSchemaRevisionRequest request, - io.grpc.stub.StreamObserver
- * Deletes a schema. - *- */ - default void deleteSchema( - com.google.pubsub.v1.DeleteSchemaRequest request, - io.grpc.stub.StreamObserver
- * Validates a schema. - *- */ - default void validateSchema( - com.google.pubsub.v1.ValidateSchemaRequest request, - io.grpc.stub.StreamObserver
- * Validates a message against a schema. - *- */ - default void validateMessage( - com.google.pubsub.v1.ValidateMessageRequest request, - io.grpc.stub.StreamObserver
- * Service for doing schema-related operations. - *- */ - public abstract static class SchemaServiceImplBase - implements io.grpc.BindableService, AsyncService { - - @java.lang.Override - public final io.grpc.ServerServiceDefinition bindService() { - return SchemaServiceGrpc.bindService(this); - } - } - - /** - * A stub to allow clients to do asynchronous rpc calls to service SchemaService. - * - *
- * Service for doing schema-related operations. - *- */ - public static final class SchemaServiceStub - extends io.grpc.stub.AbstractAsyncStub
- * Creates a schema. - *- */ - public void createSchema( - com.google.pubsub.v1.CreateSchemaRequest request, - io.grpc.stub.StreamObserver
- * Gets a schema. - *- */ - public void getSchema( - com.google.pubsub.v1.GetSchemaRequest request, - io.grpc.stub.StreamObserver
- * Lists schemas in a project. - *- */ - public void listSchemas( - com.google.pubsub.v1.ListSchemasRequest request, - io.grpc.stub.StreamObserver
- * Lists all schema revisions for the named schema. - *- */ - public void listSchemaRevisions( - com.google.pubsub.v1.ListSchemaRevisionsRequest request, - io.grpc.stub.StreamObserver
- * Commits a new schema revision to an existing schema. - *- */ - public void commitSchema( - com.google.pubsub.v1.CommitSchemaRequest request, - io.grpc.stub.StreamObserver
- * Creates a new schema revision that is a copy of the provided revision_id. - *- */ - public void rollbackSchema( - com.google.pubsub.v1.RollbackSchemaRequest request, - io.grpc.stub.StreamObserver
- * Deletes a specific schema revision. - *- */ - public void deleteSchemaRevision( - com.google.pubsub.v1.DeleteSchemaRevisionRequest request, - io.grpc.stub.StreamObserver
- * Deletes a schema. - *- */ - public void deleteSchema( - com.google.pubsub.v1.DeleteSchemaRequest request, - io.grpc.stub.StreamObserver
- * Validates a schema. - *- */ - public void validateSchema( - com.google.pubsub.v1.ValidateSchemaRequest request, - io.grpc.stub.StreamObserver
- * Validates a message against a schema. - *- */ - public void validateMessage( - com.google.pubsub.v1.ValidateMessageRequest request, - io.grpc.stub.StreamObserver
- * Service for doing schema-related operations. - *- */ - public static final class SchemaServiceBlockingStub - extends io.grpc.stub.AbstractBlockingStub
- * Creates a schema. - *- */ - public com.google.pubsub.v1.Schema createSchema( - com.google.pubsub.v1.CreateSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getCreateSchemaMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Gets a schema. - *- */ - public com.google.pubsub.v1.Schema getSchema(com.google.pubsub.v1.GetSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getGetSchemaMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Lists schemas in a project. - *- */ - public com.google.pubsub.v1.ListSchemasResponse listSchemas( - com.google.pubsub.v1.ListSchemasRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getListSchemasMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Lists all schema revisions for the named schema. - *- */ - public com.google.pubsub.v1.ListSchemaRevisionsResponse listSchemaRevisions( - com.google.pubsub.v1.ListSchemaRevisionsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getListSchemaRevisionsMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Commits a new schema revision to an existing schema. - *- */ - public com.google.pubsub.v1.Schema commitSchema( - com.google.pubsub.v1.CommitSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getCommitSchemaMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Creates a new schema revision that is a copy of the provided revision_id. - *- */ - public com.google.pubsub.v1.Schema rollbackSchema( - com.google.pubsub.v1.RollbackSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getRollbackSchemaMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Deletes a specific schema revision. - *- */ - public com.google.pubsub.v1.Schema deleteSchemaRevision( - com.google.pubsub.v1.DeleteSchemaRevisionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getDeleteSchemaRevisionMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Deletes a schema. - *- */ - public com.google.protobuf.Empty deleteSchema( - com.google.pubsub.v1.DeleteSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getDeleteSchemaMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Validates a schema. - *- */ - public com.google.pubsub.v1.ValidateSchemaResponse validateSchema( - com.google.pubsub.v1.ValidateSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getValidateSchemaMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Validates a message against a schema. - *- */ - public com.google.pubsub.v1.ValidateMessageResponse validateMessage( - com.google.pubsub.v1.ValidateMessageRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getValidateMessageMethod(), getCallOptions(), request); - } - } - - /** - * A stub to allow clients to do ListenableFuture-style rpc calls to service SchemaService. - * - *
- * Service for doing schema-related operations. - *- */ - public static final class SchemaServiceFutureStub - extends io.grpc.stub.AbstractFutureStub
- * Creates a schema. - *- */ - public com.google.common.util.concurrent.ListenableFuture
- * Gets a schema. - *- */ - public com.google.common.util.concurrent.ListenableFuture
- * Lists schemas in a project. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.pubsub.v1.ListSchemasResponse> - listSchemas(com.google.pubsub.v1.ListSchemasRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getListSchemasMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Lists all schema revisions for the named schema. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.pubsub.v1.ListSchemaRevisionsResponse> - listSchemaRevisions(com.google.pubsub.v1.ListSchemaRevisionsRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getListSchemaRevisionsMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Commits a new schema revision to an existing schema. - *- */ - public com.google.common.util.concurrent.ListenableFuture
- * Creates a new schema revision that is a copy of the provided revision_id. - *- */ - public com.google.common.util.concurrent.ListenableFuture
- * Deletes a specific schema revision. - *- */ - public com.google.common.util.concurrent.ListenableFuture
- * Deletes a schema. - *- */ - public com.google.common.util.concurrent.ListenableFuture
- * Validates a schema. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.pubsub.v1.ValidateSchemaResponse> - validateSchema(com.google.pubsub.v1.ValidateSchemaRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getValidateSchemaMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Validates a message against a schema. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.pubsub.v1.ValidateMessageResponse> - validateMessage(com.google.pubsub.v1.ValidateMessageRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getValidateMessageMethod(), getCallOptions()), request); - } - } - - private static final int METHODID_CREATE_SCHEMA = 0; - private static final int METHODID_GET_SCHEMA = 1; - private static final int METHODID_LIST_SCHEMAS = 2; - private static final int METHODID_LIST_SCHEMA_REVISIONS = 3; - private static final int METHODID_COMMIT_SCHEMA = 4; - private static final int METHODID_ROLLBACK_SCHEMA = 5; - private static final int METHODID_DELETE_SCHEMA_REVISION = 6; - private static final int METHODID_DELETE_SCHEMA = 7; - private static final int METHODID_VALIDATE_SCHEMA = 8; - private static final int METHODID_VALIDATE_MESSAGE = 9; - - private static final class MethodHandlers
If the name is not provided in the request, the server will assign a random name for this - * subscription on the same project as the topic, conforming to the [resource name - * format](https://cloud.google.com/pubsub/docs/admin#resource_names). The generated name is - * populated in the returned Subscription object. Note that for REST API requests, you must - * specify a name in the request. - * - *
Sample code: - * - *
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * ProjectTopicName topic = ProjectTopicName.of("[PROJECT]", "[TOPIC]");
- * PushConfig pushConfig = PushConfig.newBuilder().build();
- * int ackDeadlineSeconds = 0;
- * Subscription response = subscriptionAdminClient.createSubscription(name, topic, pushConfig, ackDeadlineSeconds);
- * }
- * For pull subscriptions, this value is used as the initial value for the ack deadline. To - * override this value for a given message, call `ModifyAckDeadline` with the corresponding - * `ack_id` if using non-streaming pull or send the `ack_id` in a - * `StreamingModifyAckDeadlineRequest` if using streaming pull. The minimum custom deadline - * you can specify is 10 seconds. The maximum custom deadline you can specify is 600 seconds - * (10 minutes). If this parameter is 0, a default value of 10 seconds is used. - *
For push delivery, this value is also used to set the request timeout for the call to - * the push endpoint. - *
If the subscriber never acknowledges the message, the Pub/Sub system will eventually - * redeliver the message. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #createSubscription(SubscriptionName, TopicName, PushConfig, int)} - * instead. - */ - @Deprecated - public final Subscription createSubscription( - ProjectSubscriptionName name, - ProjectTopicName topic, - PushConfig pushConfig, - int ackDeadlineSeconds) { - Subscription request = - Subscription.newBuilder() - .setName(name == null ? null : name.toString()) - .setTopic(topic == null ? null : topic.toString()) - .setPushConfig(pushConfig) - .setAckDeadlineSeconds(ackDeadlineSeconds) - .build(); - return createSubscription(request); - } - - // AUTO-GENERATED DOCUMENTATION AND METHOD. - /** - * Creates a subscription to a given topic. See the [resource name rules] - * (https://cloud.google.com/pubsub/docs/admin#resource_names). If the subscription already - * exists, returns `ALREADY_EXISTS`. If the corresponding topic doesn't exist, returns - * `NOT_FOUND`. - * - *
If the name is not provided in the request, the server will assign a random name for this - * subscription on the same project as the topic, conforming to the [resource name format] - * (https://cloud.google.com/pubsub/docs/admin#resource_names). The generated name is populated in - * the returned Subscription object. Note that for REST API requests, you must specify a name in - * the request. - * - *
Sample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * String topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString();
- * PushConfig pushConfig = PushConfig.newBuilder().build();
- * int ackDeadlineSeconds = 2135351438;
- * Subscription response =
- * subscriptionAdminClient.createSubscription(name, topic, pushConfig, ackDeadlineSeconds);
- * }
- * }
- *
- * @param name Required. The name of the subscription. It must have the format
- * `"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must start with a
- * letter, and contain only letters (`[A-Za-z]`), numbers (`[0-9]`), dashes (`-`), underscores
- * (`_`), periods (`.`), tildes (`~`), plus (`+`) or percent signs (`%`). It must be between 3
- * and 255 characters in length, and it must not start with `"goog"`.
- * @param topic Required. The name of the topic from which this subscription is receiving
- * messages. Format is `projects/{project}/topics/{topic}`. The value of this field will be
- * `_deleted-topic_` if the topic has been deleted.
- * @param pushConfig If push delivery is used with this subscription, this field is used to
- * configure it. An empty `pushConfig` signifies that the subscriber will pull and ack
- * messages using API methods.
- * @param ackDeadlineSeconds The approximate amount of time (on a best-effort basis) Pub/Sub waits
- * for the subscriber to acknowledge receipt before resending the message. In the interval
- * after the message is delivered and before it is acknowledged, it is considered to be
- * <i>outstanding</i>. During that time period, the message will not be
- * redelivered (on a best-effort basis).
- * For pull subscriptions, this value is used as the initial value for the ack deadline. To - * override this value for a given message, call `ModifyAckDeadline` with the corresponding - * `ack_id` if using non-streaming pull or send the `ack_id` in a - * `StreamingModifyAckDeadlineRequest` if using streaming pull. The minimum custom deadline - * you can specify is 10 seconds. The maximum custom deadline you can specify is 600 seconds - * (10 minutes). If this parameter is 0, a default value of 10 seconds is used. - *
For push delivery, this value is also used to set the request timeout for the call to - * the push endpoint. - *
If the subscriber never acknowledges the message, the Pub/Sub system will eventually - * redeliver the message. - * @deprecated Use {@link #createSubscription(SubscriptionName, String, PushConfig, int)} instead. - */ - @Deprecated - public final Subscription createSubscription( - ProjectSubscriptionName name, String topic, PushConfig pushConfig, int ackDeadlineSeconds) { - Subscription request = - Subscription.newBuilder() - .setName(name == null ? null : name.toString()) - .setTopic(topic) - .setPushConfig(pushConfig) - .setAckDeadlineSeconds(ackDeadlineSeconds) - .build(); - return createSubscription(request); - } - - // AUTO-GENERATED DOCUMENTATION AND METHOD. - /** - * Creates a subscription to a given topic. See the [resource name rules] - * (https://cloud.google.com/pubsub/docs/admin#resource_names). If the subscription already - * exists, returns `ALREADY_EXISTS`. If the corresponding topic doesn't exist, returns - * `NOT_FOUND`. - * - *
If the name is not provided in the request, the server will assign a random name for this - * subscription on the same project as the topic, conforming to the [resource name format] - * (https://cloud.google.com/pubsub/docs/admin#resource_names). The generated name is populated in - * the returned Subscription object. Note that for REST API requests, you must specify a name in - * the request. - * - *
Sample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]");
- * PushConfig pushConfig = PushConfig.newBuilder().build();
- * int ackDeadlineSeconds = 2135351438;
- * Subscription response =
- * subscriptionAdminClient.createSubscription(name, topic, pushConfig, ackDeadlineSeconds);
- * }
- * }
- *
- * @param name Required. The name of the subscription. It must have the format
- * `"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must start with a
- * letter, and contain only letters (`[A-Za-z]`), numbers (`[0-9]`), dashes (`-`), underscores
- * (`_`), periods (`.`), tildes (`~`), plus (`+`) or percent signs (`%`). It must be between 3
- * and 255 characters in length, and it must not start with `"goog"`.
- * @param topic Required. The name of the topic from which this subscription is receiving
- * messages. Format is `projects/{project}/topics/{topic}`. The value of this field will be
- * `_deleted-topic_` if the topic has been deleted.
- * @param pushConfig If push delivery is used with this subscription, this field is used to
- * configure it. An empty `pushConfig` signifies that the subscriber will pull and ack
- * messages using API methods.
- * @param ackDeadlineSeconds The approximate amount of time (on a best-effort basis) Pub/Sub waits
- * for the subscriber to acknowledge receipt before resending the message. In the interval
- * after the message is delivered and before it is acknowledged, it is considered to be
- * <i>outstanding</i>. During that time period, the message will not be
- * redelivered (on a best-effort basis).
- * For pull subscriptions, this value is used as the initial value for the ack deadline. To - * override this value for a given message, call `ModifyAckDeadline` with the corresponding - * `ack_id` if using non-streaming pull or send the `ack_id` in a - * `StreamingModifyAckDeadlineRequest` if using streaming pull. The minimum custom deadline - * you can specify is 10 seconds. The maximum custom deadline you can specify is 600 seconds - * (10 minutes). If this parameter is 0, a default value of 10 seconds is used. - *
For push delivery, this value is also used to set the request timeout for the call to - * the push endpoint. - *
If the subscriber never acknowledges the message, the Pub/Sub system will eventually - * redeliver the message. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #createSubscription(SubscriptionName, TopicName, PushConfig, int)} - * instead. - */ - @Deprecated - public final Subscription createSubscription( - ProjectSubscriptionName name, - TopicName topic, - PushConfig pushConfig, - int ackDeadlineSeconds) { - Subscription request = - Subscription.newBuilder() - .setName(name == null ? null : name.toString()) - .setTopic(topic == null ? null : topic.toString()) - .setPushConfig(pushConfig) - .setAckDeadlineSeconds(ackDeadlineSeconds) - .build(); - return createSubscription(request); - } - // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Creates a subscription to a given topic. See the [resource name rules] @@ -1239,33 +1026,6 @@ public final Subscription getSubscription(GetSubscriptionRequest request) { return getSubscriptionCallable().call(request); } - // AUTO-GENERATED DOCUMENTATION AND METHOD. - /** - * Gets the configuration details of a subscription. - * - *
Sample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * Subscription response = subscriptionAdminClient.getSubscription(subscription);
- * }
- * }
- *
- * @param subscription Required. The name of the subscription to get. Format is
- * `projects/{project}/subscriptions/{sub}`.
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- * @deprecated Use {@link #getSubscription(SubscriptionName)} instead.
- */
- @Deprecated
- public final Subscription getSubscription(ProjectSubscriptionName subscription) {
- GetSubscriptionRequest request =
- GetSubscriptionRequest.newBuilder()
- .setSubscription(subscription == null ? null : subscription.toString())
- .build();
- return getSubscription(request);
- }
-
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Gets the configuration details of a subscription.
@@ -1650,36 +1410,6 @@ public final void deleteSubscription(DeleteSubscriptionRequest request) {
deleteSubscriptionCallable().call(request);
}
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Deletes an existing subscription. All messages retained in the subscription are immediately
- * dropped. Calls to `Pull` after deletion will return `NOT_FOUND`. After a subscription is
- * deleted, a new one may be created with the same name, but the new one has no association with
- * the old subscription or its topic unless the same topic is specified.
- *
- * Sample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * subscriptionAdminClient.deleteSubscription(subscription);
- * }
- * }
- *
- * @param subscription Required. The subscription to delete. Format is
- * `projects/{project}/subscriptions/{sub}`.
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- * @deprecated Use {@link #deleteSubscription(SubscriptionName)} instead.
- */
- @Deprecated
- public final void deleteSubscription(ProjectSubscriptionName subscription) {
- DeleteSubscriptionRequest request =
- DeleteSubscriptionRequest.newBuilder()
- .setSubscription(subscription == null ? null : subscription.toString())
- .build();
- deleteSubscription(request);
- }
-
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Deletes an existing subscription. All messages retained in the subscription are immediately
@@ -1836,49 +1566,6 @@ public final void modifyAckDeadline(ModifyAckDeadlineRequest request) {
modifyAckDeadlineCallable().call(request);
}
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Modifies the ack deadline for a specific message. This method is useful to indicate that more
- * time is needed to process a message by the subscriber, or to make the message available for
- * redelivery if the processing was interrupted. Note that this does not modify the
- * subscription-level `ackDeadlineSeconds` used for subsequent messages.
- *
- * Sample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * List ackIds = new ArrayList<>();
- * int ackDeadlineSeconds = 2135351438;
- * subscriptionAdminClient.modifyAckDeadline(subscription, ackIds, ackDeadlineSeconds);
- * }
- * }
- *
- * @param subscription Required. The name of the subscription. Format is
- * `projects/{project}/subscriptions/{sub}`.
- * @param ackIds Required. List of acknowledgment IDs.
- * @param ackDeadlineSeconds Required. The new ack deadline with respect to the time this request
- * was sent to the Pub/Sub system. For example, if the value is 10, the new ack deadline will
- * expire 10 seconds after the `ModifyAckDeadline` call was made. Specifying zero might
- * immediately make the message available for delivery to another subscriber client. This
- * typically results in an increase in the rate of message redeliveries (that is, duplicates).
- * The minimum deadline you can specify is 0 seconds. The maximum deadline you can specify is
- * 600 seconds (10 minutes).
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- * @deprecated Use {@link #modifyAckDeadline(SubscriptionName, ListAcknowledging a message whose ack deadline has expired may succeed, but such a message may - * be redelivered later. Acknowledging a message more than once will not result in an error. - * - *
Sample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * List ackIds = new ArrayList<>();
- * subscriptionAdminClient.acknowledge(subscription, ackIds);
- * }
- * }
- *
- * @param subscription Required. The subscription whose message is being acknowledged. Format is
- * `projects/{project}/subscriptions/{sub}`.
- * @param ackIds Required. The acknowledgment ID for the messages being acknowledged that was
- * returned by the Pub/Sub system in the `Pull` response. Must not be empty.
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- * @deprecated Use {@link #acknowledge(SubscriptionName, ListSample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * int maxMessages = 496131527;
- * PullResponse response = subscriptionAdminClient.pull(subscription, maxMessages);
- * }
- * }
- *
- * @param subscription Required. The subscription from which messages should be pulled. Format is
- * `projects/{project}/subscriptions/{sub}`.
- * @param maxMessages Required. The maximum number of messages to return for this request. Must be
- * a positive integer. The Pub/Sub system may return fewer than the number specified.
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- * @deprecated Use {@link #pull(SubscriptionName, int)} instead.
- */
- @Deprecated
- public final PullResponse pull(ProjectSubscriptionName subscription, int maxMessages) {
- PullRequest request =
- PullRequest.newBuilder()
- .setSubscription(subscription == null ? null : subscription.toString())
- .setMaxMessages(maxMessages)
- .build();
- return pull(request);
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Pulls messages from the server. The server may return `UNAVAILABLE` if there are too many
- * concurrent pull requests pending for the given subscription.
- *
- * Sample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * boolean returnImmediately = true;
- * int maxMessages = 496131527;
- * PullResponse response =
- * subscriptionAdminClient.pull(subscription, returnImmediately, maxMessages);
- * }
- * }
- *
- * @param subscription Required. The subscription from which messages should be pulled. Format is
- * `projects/{project}/subscriptions/{sub}`.
- * @param returnImmediately Optional. If this field set to true, the system will respond
- * immediately even if it there are no messages available to return in the `Pull` response.
- * Otherwise, the system may wait (for a bounded amount of time) until at least one message is
- * available, rather than returning no messages. Warning: setting this field to `true` is
- * discouraged because it adversely impacts the performance of `Pull` operations. We recommend
- * that users do not set this field.
- * @param maxMessages Required. The maximum number of messages to return for this request. Must be
- * a positive integer. The Pub/Sub system may return fewer than the number specified.
+ * .setMaxMessages(496131527)
+ * .build();
+ * PullResponse response = subscriptionAdminClient.pull(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
- * @deprecated Use {@link #pull(SubscriptionName, boolean, int)} instead.
*/
- @Deprecated
- final PullResponse pull(
- ProjectSubscriptionName subscription, boolean returnImmediately, int maxMessages) {
- PullRequest request =
- PullRequest.newBuilder()
- .setSubscription(subscription == null ? null : subscription.toString())
- .setReturnImmediately(returnImmediately)
- .setMaxMessages(maxMessages)
- .build();
- return pull(request);
+ public final PullResponse pull(PullRequest request) {
+ return pullCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD.
@@ -2529,44 +2107,6 @@ public final void modifyPushConfig(ModifyPushConfigRequest request) {
modifyPushConfigCallable().call(request);
}
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Modifies the `PushConfig` for a specified subscription.
- *
- * This may be used to change a push subscription to a pull one (signified by an empty - * `PushConfig`) or vice versa, or change the endpoint URL and other attributes of a push - * subscription. Messages will accumulate for delivery continuously through the call regardless of - * changes to the `PushConfig`. - * - *
Sample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * PushConfig pushConfig = PushConfig.newBuilder().build();
- * subscriptionAdminClient.modifyPushConfig(subscription, pushConfig);
- * }
- * }
- *
- * @param subscription Required. The name of the subscription. Format is
- * `projects/{project}/subscriptions/{sub}`.
- * @param pushConfig Required. The push configuration for future deliveries.
- * An empty `pushConfig` indicates that the Pub/Sub system should stop pushing messages - * from the given subscription and allow messages to be pulled and acknowledged - effectively - * pausing the subscription if `Pull` or `StreamingPull` is not called. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #modifyPushConfig(SubscriptionName, PushConfig)} instead. - */ - @Deprecated - public final void modifyPushConfig(ProjectSubscriptionName subscription, PushConfig pushConfig) { - ModifyPushConfigRequest request = - ModifyPushConfigRequest.newBuilder() - .setSubscription(subscription == null ? null : subscription.toString()) - .setPushConfig(pushConfig) - .build(); - modifyPushConfig(request); - } - // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Modifies the `PushConfig` for a specified subscription. @@ -2695,36 +2235,6 @@ public final Snapshot getSnapshot(GetSnapshotRequest request) { return getSnapshotCallable().call(request); } - // AUTO-GENERATED DOCUMENTATION AND METHOD. - /** - * Gets the configuration details of a snapshot. Snapshots are used in <a - * href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which - * allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment - * state of messages in an existing subscription to the state captured by a snapshot. - * - *
Sample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]");
- * Snapshot response = subscriptionAdminClient.getSnapshot(snapshot);
- * }
- * }
- *
- * @param snapshot Required. The name of the snapshot to get. Format is
- * `projects/{project}/snapshots/{snap}`.
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- * @deprecated Use Use {@link #getSnapshot(SnapshotName)} instead.
- */
- @Deprecated
- public final Snapshot getSnapshot(ProjectSnapshotName snapshot) {
- GetSnapshotRequest request =
- GetSnapshotRequest.newBuilder()
- .setSnapshot(snapshot == null ? null : snapshot.toString())
- .build();
- return getSnapshot(request);
- }
-
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Gets the configuration details of a snapshot. Snapshots are used in
@@ -3186,157 +2696,6 @@ public final Snapshot createSnapshot(CreateSnapshotRequest request) {
return createSnapshotCallable().call(request);
}
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Creates a snapshot from the requested subscription. Snapshots are used in
- * [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations, which allow you to
- * manage message acknowledgments in bulk. That is, you can set the acknowledgment state of
- * messages in an existing subscription to the state captured by a snapshot. If the snapshot
- * already exists, returns `ALREADY_EXISTS`. If the requested subscription doesn't exist, returns
- * `NOT_FOUND`. If the backlog in the subscription is too old -- and the resulting snapshot would
- * expire in less than 1 hour -- then `FAILED_PRECONDITION` is returned. See also the
- * `Snapshot.expire_time` field. If the name is not provided in the request, the server will
- * assign a random name for this snapshot on the same project as the subscription, conforming to
- * the [resource name format] (https://cloud.google.com/pubsub/docs/admin#resource_names). The
- * generated name is populated in the returned Snapshot object. Note that for REST API requests,
- * you must specify a name in the request.
- *
- * Sample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSnapshotName name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]");
- * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription);
- * }
- * }
- *
- * @param name Required. User-provided name for this snapshot. If the name is not provided in the
- * request, the server will assign a random name for this snapshot on the same project as the
- * subscription. Note that for REST API requests, you must specify a name. See the <a
- * href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource name
- * rules</a>. Format is `projects/{project}/snapshots/{snap}`.
- * @param subscription Required. The subscription whose backlog the snapshot retains.
- * Specifically, the created snapshot is guaranteed to retain: (a) The existing backlog on the
- * subscription. More precisely, this is defined as the messages in the subscription's backlog
- * that are unacknowledged upon the successful completion of the `CreateSnapshot` request; as
- * well as: (b) Any messages published to the subscription's topic following the successful
- * completion of the CreateSnapshot request. Format is
- * `projects/{project}/subscriptions/{sub}`.
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- * @deprecated Use Use {@link #createSnapshot(SnapshotName, SubscriptionName)} instead.
- */
- @Deprecated
- public final Snapshot createSnapshot(
- ProjectSnapshotName name, ProjectSubscriptionName subscription) {
- CreateSnapshotRequest request =
- CreateSnapshotRequest.newBuilder()
- .setName(name == null ? null : name.toString())
- .setSubscription(subscription == null ? null : subscription.toString())
- .build();
- return createSnapshot(request);
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Creates a snapshot from the requested subscription. Snapshots are used in
- * [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations, which allow you to
- * manage message acknowledgments in bulk. That is, you can set the acknowledgment state of
- * messages in an existing subscription to the state captured by a snapshot. If the snapshot
- * already exists, returns `ALREADY_EXISTS`. If the requested subscription doesn't exist, returns
- * `NOT_FOUND`. If the backlog in the subscription is too old -- and the resulting snapshot would
- * expire in less than 1 hour -- then `FAILED_PRECONDITION` is returned. See also the
- * `Snapshot.expire_time` field. If the name is not provided in the request, the server will
- * assign a random name for this snapshot on the same project as the subscription, conforming to
- * the [resource name format] (https://cloud.google.com/pubsub/docs/admin#resource_names). The
- * generated name is populated in the returned Snapshot object. Note that for REST API requests,
- * you must specify a name in the request.
- *
- * Sample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * String name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString();
- * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
- * Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription);
- * }
- * }
- *
- * @param name Required. User-provided name for this snapshot. If the name is not provided in the
- * request, the server will assign a random name for this snapshot on the same project as the
- * subscription. Note that for REST API requests, you must specify a name. See the <a
- * href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource name
- * rules</a>. Format is `projects/{project}/snapshots/{snap}`.
- * @param subscription Required. The subscription whose backlog the snapshot retains.
- * Specifically, the created snapshot is guaranteed to retain: (a) The existing backlog on the
- * subscription. More precisely, this is defined as the messages in the subscription's backlog
- * that are unacknowledged upon the successful completion of the `CreateSnapshot` request; as
- * well as: (b) Any messages published to the subscription's topic following the successful
- * completion of the CreateSnapshot request. Format is
- * `projects/{project}/subscriptions/{sub}`.
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- * @deprecated Use Use {@link #createSnapshot(String, SubscriptionName)} instead.
- */
- @Deprecated
- public final Snapshot createSnapshot(String name, ProjectSubscriptionName subscription) {
- CreateSnapshotRequest request =
- CreateSnapshotRequest.newBuilder()
- .setName(name)
- .setSubscription(subscription == null ? null : subscription.toString())
- .build();
- return createSnapshot(request);
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Creates a snapshot from the requested subscription. Snapshots are used in
- * [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations, which allow you to
- * manage message acknowledgments in bulk. That is, you can set the acknowledgment state of
- * messages in an existing subscription to the state captured by a snapshot. If the snapshot
- * already exists, returns `ALREADY_EXISTS`. If the requested subscription doesn't exist, returns
- * `NOT_FOUND`. If the backlog in the subscription is too old -- and the resulting snapshot would
- * expire in less than 1 hour -- then `FAILED_PRECONDITION` is returned. See also the
- * `Snapshot.expire_time` field. If the name is not provided in the request, the server will
- * assign a random name for this snapshot on the same project as the subscription, conforming to
- * the [resource name format] (https://cloud.google.com/pubsub/docs/admin#resource_names). The
- * generated name is populated in the returned Snapshot object. Note that for REST API requests,
- * you must specify a name in the request.
- *
- * Sample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSnapshotName name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]");
- * String subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
- * Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription);
- * }
- * }
- *
- * @param name Required. User-provided name for this snapshot. If the name is not provided in the
- * request, the server will assign a random name for this snapshot on the same project as the
- * subscription. Note that for REST API requests, you must specify a name. See the <a
- * href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource name
- * rules</a>. Format is `projects/{project}/snapshots/{snap}`.
- * @param subscription Required. The subscription whose backlog the snapshot retains.
- * Specifically, the created snapshot is guaranteed to retain: (a) The existing backlog on the
- * subscription. More precisely, this is defined as the messages in the subscription's backlog
- * that are unacknowledged upon the successful completion of the `CreateSnapshot` request; as
- * well as: (b) Any messages published to the subscription's topic following the successful
- * completion of the CreateSnapshot request. Format is
- * `projects/{project}/subscriptions/{sub}`.
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- * @deprecated Use Use {@link #createSnapshot(SnapshotName, String)} instead.
- */
- @Deprecated
- public final Snapshot createSnapshot(ProjectSnapshotName name, String subscription) {
- CreateSnapshotRequest request =
- CreateSnapshotRequest.newBuilder()
- .setName(name == null ? null : name.toString())
- .setSubscription(subscription)
- .build();
- return createSnapshot(request);
- }
-
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Creates a snapshot from the requested subscription. Snapshots are used in
@@ -3579,39 +2938,6 @@ public final void deleteSnapshot(DeleteSnapshotRequest request) {
deleteSnapshotCallable().call(request);
}
- // AUTO-GENERATED DOCUMENTATION AND METHOD.
- /**
- * Removes an existing snapshot. Snapshots are used in [Seek]
- * (https://cloud.google.com/pubsub/docs/replay-overview) operations, which allow you to manage
- * message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in
- * an existing subscription to the state captured by a snapshot. When the snapshot is deleted, all
- * messages retained in the snapshot are immediately dropped. After a snapshot is deleted, a new
- * one may be created with the same name, but the new one has no association with the old snapshot
- * or its subscription, unless the same subscription is specified.
- *
- * Sample code: - * - *
{@code
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]");
- * subscriptionAdminClient.deleteSnapshot(snapshot);
- * }
- * }
- *
- * @param snapshot Required. The name of the snapshot to delete. Format is
- * `projects/{project}/snapshots/{snap}`.
- * @throws com.google.api.gax.rpc.ApiException if the remote call fails
- * @deprecated Use Use {@link #deleteSnapshot(SnapshotName)} instead.
- */
- @Deprecated
- public final void deleteSnapshot(ProjectSnapshotName snapshot) {
- DeleteSnapshotRequest request =
- DeleteSnapshotRequest.newBuilder()
- .setSnapshot(snapshot == null ? null : snapshot.toString())
- .build();
- deleteSnapshot(request);
- }
-
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Removes an existing snapshot. Snapshots are used in [Seek]
@@ -3743,37 +3069,6 @@ public final Policy setIamPolicy(SetIamPolicyRequest request) {
return setIamPolicyCallable().call(request);
}
- // AUTO-GENERATED DOCUMENTATION AND METHOD
- /**
- * Sets the access control policy on the specified resource. Replaces any existing policy.
- *
- * Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED - * - *
Sample code: - * - *
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * String formattedResource = ProjectTopicName.format("[PROJECT]", "[TOPIC]");
- * Policy policy = Policy.newBuilder().build();
- * Policy response = subscriptionAdminClient.setIamPolicy(formattedResource, policy);
- * }
- * Sample code: - * - *
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * String formattedResource = ProjectTopicName.format("[PROJECT]", "[TOPIC]");
- * Policy response = subscriptionAdminClient.getIamPolicy(formattedResource);
- * }
- * Note: This operation is designed to be used for building permission-aware UIs and - * command-line tools, not for authorization checking. This operation may "fail open" without - * warning. - * - *
Sample code: - * - *
- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
- * String formattedResource = ProjectTopicName.format("[PROJECT]", "[TOPIC]");
- * List<String> permissions = new ArrayList<>();
- * TestIamPermissionsResponse response = subscriptionAdminClient.testIamPermissions(formattedResource, permissions);
- * }
- * Sample code: - * - *
- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
- * ProjectTopicName name = ProjectTopicName.of("[PROJECT]", "[TOPIC]");
- * Topic response = topicAdminClient.createTopic(name);
- * }
- * Sample code: - * - *
- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
- * ProjectTopicName topic = ProjectTopicName.of("[PROJECT]", "[TOPIC]");
- * Topic response = topicAdminClient.getTopic(topic);
- * }
- * Sample code: - * - *
- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
- * ProjectTopicName topic = ProjectTopicName.of("[PROJECT]", "[TOPIC]");
- * for (ProjectSubscriptionName element : topicAdminClient.listTopicSubscriptions(topic).iterateAllAsProjectSubscriptionName()) {
- * // doThingsWith(element);
- * }
- * }
- * Sample code: - * - *
- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
- * ProjectTopicName topic = ProjectTopicName.of("[PROJECT]", "[TOPIC]");
- * topicAdminClient.deleteTopic(topic);
- * }
- * Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED - * - *
Sample code: - * - *
- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
- * String formattedResource = ProjectTopicName.format("[PROJECT]", "[TOPIC]");
- * Policy policy = Policy.newBuilder().build();
- * Policy response = topicAdminClient.setIamPolicy(formattedResource, policy);
- * }
- * Sample code: - * - *
- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
- * String formattedResource = ProjectTopicName.format("[PROJECT]", "[TOPIC]");
- * Policy response = topicAdminClient.getIamPolicy(formattedResource);
- * }
- * Note: This operation is designed to be used for building permission-aware UIs and - * command-line tools, not for authorization checking. This operation may "fail open" without - * warning. - * - *
Sample code: - * - *
- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
- * String formattedResource = ProjectTopicName.format("[PROJECT]", "[TOPIC]");
- * List<String> permissions = new ArrayList<>();
- * TestIamPermissionsResponse response = topicAdminClient.testIamPermissions(formattedResource, permissions);
- * }
- * This class is for advanced usage.
*/
@Generated("by gapic-generator-java")
-@BetaApi
public class HttpJsonPublisherCallableFactory
implements HttpJsonStubCallableFactory This class is for advanced usage and reflects the underlying API directly.
*/
@Generated("by gapic-generator-java")
-@BetaApi
public class HttpJsonPublisherStub extends PublisherStub {
private static final TypeRegistry typeRegistry = TypeRegistry.newBuilder().build();
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/HttpJsonSchemaServiceCallableFactory.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/HttpJsonSchemaServiceCallableFactory.java
similarity index 96%
rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/HttpJsonSchemaServiceCallableFactory.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/HttpJsonSchemaServiceCallableFactory.java
index 049e3978e..c4dedadb0 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/HttpJsonSchemaServiceCallableFactory.java
+++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/HttpJsonSchemaServiceCallableFactory.java
@@ -16,7 +16,6 @@
package com.google.cloud.pubsub.v1.stub;
-import com.google.api.core.BetaApi;
import com.google.api.gax.httpjson.HttpJsonCallSettings;
import com.google.api.gax.httpjson.HttpJsonCallableFactory;
import com.google.api.gax.httpjson.HttpJsonOperationSnapshotCallable;
@@ -41,7 +40,6 @@
* This class is for advanced usage.
*/
@Generated("by gapic-generator-java")
-@BetaApi
public class HttpJsonSchemaServiceCallableFactory
implements HttpJsonStubCallableFactory This class is for advanced usage and reflects the underlying API directly.
*/
@Generated("by gapic-generator-java")
-@BetaApi
public class HttpJsonSchemaServiceStub extends SchemaServiceStub {
private static final TypeRegistry typeRegistry = TypeRegistry.newBuilder().build();
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/HttpJsonSubscriberCallableFactory.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/HttpJsonSubscriberCallableFactory.java
similarity index 96%
rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/HttpJsonSubscriberCallableFactory.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/HttpJsonSubscriberCallableFactory.java
index 6ed7053d5..ec35b3dfe 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/HttpJsonSubscriberCallableFactory.java
+++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/HttpJsonSubscriberCallableFactory.java
@@ -16,7 +16,6 @@
package com.google.cloud.pubsub.v1.stub;
-import com.google.api.core.BetaApi;
import com.google.api.gax.httpjson.HttpJsonCallSettings;
import com.google.api.gax.httpjson.HttpJsonCallableFactory;
import com.google.api.gax.httpjson.HttpJsonOperationSnapshotCallable;
@@ -41,7 +40,6 @@
* This class is for advanced usage.
*/
@Generated("by gapic-generator-java")
-@BetaApi
public class HttpJsonSubscriberCallableFactory
implements HttpJsonStubCallableFactory This class is for advanced usage and reflects the underlying API directly.
*/
@Generated("by gapic-generator-java")
-@BetaApi
public class HttpJsonSubscriberStub extends SubscriberStub {
private static final TypeRegistry typeRegistry = TypeRegistry.newBuilder().build();
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStub.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStub.java
similarity index 100%
rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStub.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStub.java
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStubSettings.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStubSettings.java
similarity index 100%
rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStubSettings.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStubSettings.java
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStub.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStub.java
similarity index 100%
rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStub.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStub.java
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStubSettings.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStubSettings.java
similarity index 100%
rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStubSettings.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStubSettings.java
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStub.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStub.java
similarity index 100%
rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStub.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStub.java
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java
similarity index 99%
rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java
index 85c2a53d7..9720c0876 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java
+++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java
@@ -429,7 +429,8 @@ public static GoogleCredentialsProvider.Builder defaultCredentialsProviderBuilde
/** Returns a builder for the default gRPC ChannelProvider for this service. */
public static InstantiatingGrpcChannelProvider.Builder defaultGrpcTransportProviderBuilder() {
- return InstantiatingGrpcChannelProvider.newBuilder().setMaxInboundMessageSize(20 << 20);
+ return InstantiatingGrpcChannelProvider.newBuilder()
+ .setMaxInboundMessageSize(Integer.MAX_VALUE);
}
/** Returns a builder for the default REST ChannelProvider for this service. */
diff --git a/google-cloud-pubsub/src/main/resources/META-INF/native-image/com.google.cloud.pubsub.v1/reflect-config.json b/owl-bot-staging/v1/google-cloud-pubsub/src/main/resources/META-INF/native-image/com.google.cloud.pubsub.v1/reflect-config.json
similarity index 100%
rename from google-cloud-pubsub/src/main/resources/META-INF/native-image/com.google.cloud.pubsub.v1/reflect-config.json
rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/resources/META-INF/native-image/com.google.cloud.pubsub.v1/reflect-config.json
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicy.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicy.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicy.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicy.java
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicyImpl.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicyImpl.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicyImpl.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicyImpl.java
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisher.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisher.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisher.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisher.java
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisherImpl.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisherImpl.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisherImpl.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisherImpl.java
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaService.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaService.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaService.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaService.java
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaServiceImpl.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaServiceImpl.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaServiceImpl.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaServiceImpl.java
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriber.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriber.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriber.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriber.java
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriberImpl.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriberImpl.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriberImpl.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriberImpl.java
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientHttpJsonTest.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientHttpJsonTest.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientHttpJsonTest.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientHttpJsonTest.java
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientTest.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientTest.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientTest.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientTest.java
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientHttpJsonTest.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientHttpJsonTest.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientHttpJsonTest.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientHttpJsonTest.java
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientHttpJsonTest.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientHttpJsonTest.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientHttpJsonTest.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientHttpJsonTest.java
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientTest.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientTest.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientTest.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientTest.java
diff --git a/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java b/owl-bot-staging/v1/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java
similarity index 51%
rename from grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java
rename to owl-bot-staging/v1/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java
index 18d2202b1..064ea1df0 100644
--- a/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java
+++ b/owl-bot-staging/v1/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java
@@ -1,25 +1,8 @@
-/*
- * Copyright 2024 Google LLC
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * https://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
package com.google.pubsub.v1;
import static io.grpc.MethodDescriptor.generateFullMethodName;
/**
- *
- *
*
* The service that an application uses to manipulate topics, and to send
* messages to a topic.
@@ -36,423 +19,330 @@ private PublisherGrpc() {}
public static final java.lang.String SERVICE_NAME = "google.pubsub.v1.Publisher";
// Static method descriptors that strictly reflect the proto.
- private static volatile io.grpc.MethodDescriptor<
- com.google.pubsub.v1.Topic, com.google.pubsub.v1.Topic>
- getCreateTopicMethod;
+ private static volatile io.grpc.MethodDescriptor
* The service that an application uses to manipulate topics, and to send
* messages to a topic.
@@ -461,93 +351,69 @@ public PublisherFutureStub newStub(
public interface AsyncService {
/**
- *
- *
*
* Creates the given topic with the given name. See the [resource name rules]
* (https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names).
*
*/
- default void createTopic(
- com.google.pubsub.v1.Topic request,
+ default void createTopic(com.google.pubsub.v1.Topic request,
io.grpc.stub.StreamObserver
* Updates an existing topic by updating the fields specified in the update
* mask. Note that certain properties of a topic are not modifiable.
*
*/
- default void updateTopic(
- com.google.pubsub.v1.UpdateTopicRequest request,
+ default void updateTopic(com.google.pubsub.v1.UpdateTopicRequest request,
io.grpc.stub.StreamObserver
* Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic
* does not exist.
*
*/
- default void publish(
- com.google.pubsub.v1.PublishRequest request,
+ default void publish(com.google.pubsub.v1.PublishRequest request,
io.grpc.stub.StreamObserver
* Gets the configuration of a topic.
*
*/
- default void getTopic(
- com.google.pubsub.v1.GetTopicRequest request,
+ default void getTopic(com.google.pubsub.v1.GetTopicRequest request,
io.grpc.stub.StreamObserver
* Lists matching topics.
*
*/
- default void listTopics(
- com.google.pubsub.v1.ListTopicsRequest request,
+ default void listTopics(com.google.pubsub.v1.ListTopicsRequest request,
io.grpc.stub.StreamObserver
* Lists the names of the attached subscriptions on this topic.
*
*/
- default void listTopicSubscriptions(
- com.google.pubsub.v1.ListTopicSubscriptionsRequest request,
- io.grpc.stub.StreamObserver
* Lists the names of the snapshots on this topic. Snapshots are used in
* [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations,
@@ -556,17 +422,12 @@ default void listTopicSubscriptions(
* state captured by a snapshot.
*
*/
- default void listTopicSnapshots(
- com.google.pubsub.v1.ListTopicSnapshotsRequest request,
- io.grpc.stub.StreamObserver
* Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
* does not exist. After a topic is deleted, a new topic may be created with
@@ -575,16 +436,12 @@ default void listTopicSnapshots(
* not deleted, but their `topic` field is set to `_deleted-topic_`.
*
*/
- default void deleteTopic(
- com.google.pubsub.v1.DeleteTopicRequest request,
+ default void deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request,
io.grpc.stub.StreamObserver
* Detaches a subscription from this topic. All messages retained in the
* subscription are dropped. Subsequent `Pull` and `StreamingPull` requests
@@ -592,146 +449,117 @@ default void deleteTopic(
* subscription, pushes to the endpoint will stop.
*
*/
- default void detachSubscription(
- com.google.pubsub.v1.DetachSubscriptionRequest request,
- io.grpc.stub.StreamObserver
* The service that an application uses to manipulate topics, and to send
* messages to a topic.
*
*/
- public abstract static class PublisherImplBase implements io.grpc.BindableService, AsyncService {
+ public static abstract class PublisherImplBase
+ implements io.grpc.BindableService, AsyncService {
- @java.lang.Override
- public final io.grpc.ServerServiceDefinition bindService() {
+ @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
return PublisherGrpc.bindService(this);
}
}
/**
* A stub to allow clients to do asynchronous rpc calls to service Publisher.
- *
*
* The service that an application uses to manipulate topics, and to send
* messages to a topic.
*
*/
- public static final class PublisherStub extends io.grpc.stub.AbstractAsyncStub
* Creates the given topic with the given name. See the [resource name rules]
* (https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names).
*
*/
- public void createTopic(
- com.google.pubsub.v1.Topic request,
+ public void createTopic(com.google.pubsub.v1.Topic request,
io.grpc.stub.StreamObserver
* Updates an existing topic by updating the fields specified in the update
* mask. Note that certain properties of a topic are not modifiable.
*
*/
- public void updateTopic(
- com.google.pubsub.v1.UpdateTopicRequest request,
+ public void updateTopic(com.google.pubsub.v1.UpdateTopicRequest request,
io.grpc.stub.StreamObserver
* Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic
* does not exist.
*
*/
- public void publish(
- com.google.pubsub.v1.PublishRequest request,
+ public void publish(com.google.pubsub.v1.PublishRequest request,
io.grpc.stub.StreamObserver
* Gets the configuration of a topic.
*
*/
- public void getTopic(
- com.google.pubsub.v1.GetTopicRequest request,
+ public void getTopic(com.google.pubsub.v1.GetTopicRequest request,
io.grpc.stub.StreamObserver
* Lists matching topics.
*
*/
- public void listTopics(
- com.google.pubsub.v1.ListTopicsRequest request,
+ public void listTopics(com.google.pubsub.v1.ListTopicsRequest request,
io.grpc.stub.StreamObserver
* Lists the names of the attached subscriptions on this topic.
*
*/
- public void listTopicSubscriptions(
- com.google.pubsub.v1.ListTopicSubscriptionsRequest request,
- io.grpc.stub.StreamObserver
* Lists the names of the snapshots on this topic. Snapshots are used in
* [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations,
@@ -740,19 +568,13 @@ public void listTopicSubscriptions(
* state captured by a snapshot.
*
*/
- public void listTopicSnapshots(
- com.google.pubsub.v1.ListTopicSnapshotsRequest request,
- io.grpc.stub.StreamObserver
* Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
* does not exist. After a topic is deleted, a new topic may be created with
@@ -761,18 +583,13 @@ public void listTopicSnapshots(
* not deleted, but their `topic` field is set to `_deleted-topic_`.
*
*/
- public void deleteTopic(
- com.google.pubsub.v1.DeleteTopicRequest request,
+ public void deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request,
io.grpc.stub.StreamObserver
* Detaches a subscription from this topic. All messages retained in the
* subscription are dropped. Subsequent `Pull` and `StreamingPull` requests
@@ -780,20 +597,15 @@ public void deleteTopic(
* subscription, pushes to the endpoint will stop.
*
*/
- public void detachSubscription(
- com.google.pubsub.v1.DetachSubscriptionRequest request,
- io.grpc.stub.StreamObserver
* The service that an application uses to manipulate topics, and to send
* messages to a topic.
@@ -801,7 +613,8 @@ public void detachSubscription(
*/
public static final class PublisherBlockingStub
extends io.grpc.stub.AbstractBlockingStub
* Creates the given topic with the given name. See the [resource name rules]
* (https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names).
@@ -825,8 +636,6 @@ public com.google.pubsub.v1.Topic createTopic(com.google.pubsub.v1.Topic request
}
/**
- *
- *
*
* Updates an existing topic by updating the fields specified in the update
* mask. Note that certain properties of a topic are not modifiable.
@@ -838,22 +647,17 @@ public com.google.pubsub.v1.Topic updateTopic(com.google.pubsub.v1.UpdateTopicRe
}
/**
- *
- *
*
* Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic
* does not exist.
*
*/
- public com.google.pubsub.v1.PublishResponse publish(
- com.google.pubsub.v1.PublishRequest request) {
+ public com.google.pubsub.v1.PublishResponse publish(com.google.pubsub.v1.PublishRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getPublishMethod(), getCallOptions(), request);
}
/**
- *
- *
*
* Gets the configuration of a topic.
*
@@ -864,34 +668,26 @@ public com.google.pubsub.v1.Topic getTopic(com.google.pubsub.v1.GetTopicRequest
}
/**
- *
- *
*
* Lists matching topics.
*
*/
- public com.google.pubsub.v1.ListTopicsResponse listTopics(
- com.google.pubsub.v1.ListTopicsRequest request) {
+ public com.google.pubsub.v1.ListTopicsResponse listTopics(com.google.pubsub.v1.ListTopicsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListTopicsMethod(), getCallOptions(), request);
}
/**
- *
- *
*
* Lists the names of the attached subscriptions on this topic.
*
*/
- public com.google.pubsub.v1.ListTopicSubscriptionsResponse listTopicSubscriptions(
- com.google.pubsub.v1.ListTopicSubscriptionsRequest request) {
+ public com.google.pubsub.v1.ListTopicSubscriptionsResponse listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListTopicSubscriptionsMethod(), getCallOptions(), request);
}
/**
- *
- *
*
* Lists the names of the snapshots on this topic. Snapshots are used in
* [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations,
@@ -900,15 +696,12 @@ public com.google.pubsub.v1.ListTopicSubscriptionsResponse listTopicSubscription
* state captured by a snapshot.
*
*/
- public com.google.pubsub.v1.ListTopicSnapshotsResponse listTopicSnapshots(
- com.google.pubsub.v1.ListTopicSnapshotsRequest request) {
+ public com.google.pubsub.v1.ListTopicSnapshotsResponse listTopicSnapshots(com.google.pubsub.v1.ListTopicSnapshotsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListTopicSnapshotsMethod(), getCallOptions(), request);
}
/**
- *
- *
*
* Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
* does not exist. After a topic is deleted, a new topic may be created with
@@ -923,8 +716,6 @@ public com.google.protobuf.Empty deleteTopic(com.google.pubsub.v1.DeleteTopicReq
}
/**
- *
- *
*
* Detaches a subscription from this topic. All messages retained in the
* subscription are dropped. Subsequent `Pull` and `StreamingPull` requests
@@ -932,8 +723,7 @@ public com.google.protobuf.Empty deleteTopic(com.google.pubsub.v1.DeleteTopicReq
* subscription, pushes to the endpoint will stop.
*
*/
- public com.google.pubsub.v1.DetachSubscriptionResponse detachSubscription(
- com.google.pubsub.v1.DetachSubscriptionRequest request) {
+ public com.google.pubsub.v1.DetachSubscriptionResponse detachSubscription(com.google.pubsub.v1.DetachSubscriptionRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDetachSubscriptionMethod(), getCallOptions(), request);
}
@@ -941,7 +731,6 @@ public com.google.pubsub.v1.DetachSubscriptionResponse detachSubscription(
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service Publisher.
- *
*
* The service that an application uses to manipulate topics, and to send
* messages to a topic.
@@ -949,60 +738,54 @@ public com.google.pubsub.v1.DetachSubscriptionResponse detachSubscription(
*/
public static final class PublisherFutureStub
extends io.grpc.stub.AbstractFutureStub
*/
- public com.google.common.util.concurrent.ListenableFuture<
- com.google.pubsub.v1.ListTopicsResponse>
- listTopics(com.google.pubsub.v1.ListTopicsRequest request) {
+ public com.google.common.util.concurrent.ListenableFuture
* Creates the given topic with the given name. See the [resource name rules]
* (https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names).
*
*/
- public com.google.common.util.concurrent.ListenableFuture
* Updates an existing topic by updating the fields specified in the update
* mask. Note that certain properties of a topic are not modifiable.
*
*/
- public com.google.common.util.concurrent.ListenableFuture
* Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic
* does not exist.
*
*/
- public com.google.common.util.concurrent.ListenableFuture
* Gets the configuration of a topic.
*
@@ -1014,36 +797,28 @@ public com.google.common.util.concurrent.ListenableFuture
* Lists the names of the attached subscriptions on this topic.
*
*/
- public com.google.common.util.concurrent.ListenableFuture<
- com.google.pubsub.v1.ListTopicSubscriptionsResponse>
- listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request) {
+ public com.google.common.util.concurrent.ListenableFuture
* Lists the names of the snapshots on this topic. Snapshots are used in
* [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations,
@@ -1052,16 +827,13 @@ public com.google.common.util.concurrent.ListenableFuture
* Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
* does not exist. After a topic is deleted, a new topic may be created with
@@ -1070,15 +842,13 @@ public com.google.common.util.concurrent.ListenableFuture
* Detaches a subscription from this topic. All messages retained in the
* subscription are dropped. Subsequent `Pull` and `StreamingPull` requests
@@ -1086,9 +856,8 @@ public com.google.common.util.concurrent.ListenableFuture
+ * Service for doing schema-related operations.
+ *
+ */
+@javax.annotation.Generated(
+ value = "by gRPC proto compiler",
+ comments = "Source: google/pubsub/v1/schema.proto")
+@io.grpc.stub.annotations.GrpcGenerated
+public final class SchemaServiceGrpc {
+
+ private SchemaServiceGrpc() {}
+
+ public static final java.lang.String SERVICE_NAME = "google.pubsub.v1.SchemaService";
+
+ // Static method descriptors that strictly reflect the proto.
+ private static volatile io.grpc.MethodDescriptor