Class SubscriptionAdminClient (1.115.5)

Service Description: The service that an application uses to manipulate subscriptions and to consume messages from a subscription via the Pull method or by establishing a bi-directional stream using the StreamingPull method.

This class provides the ability to make remote calls to the backing service through method calls that map to API methods. Sample code to get started:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   SubscriptionName name = SubscriptionName.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);
 }
 

Note: close() needs to be called on the SubscriptionAdminClient object to clean up resources such as threads. In the example above, try-with-resources is used, which automatically calls close().

The surface of this class includes several types of Java methods for each of the API's methods:

1. A "flattened" method. With this type of method, the fields of the request type have been converted into function parameters. It may be the case that not all fields are available as parameters, and not every API method will have a flattened method entry point.
2. A "request object" method. This type of method only takes one parameter, a request object, which must be constructed before the call. Not every API method will have a request object method.
3. A "callable" method. This type of method takes no parameters and returns an immutable API callable object, which can be used to initiate calls to the service.

See the individual methods for example code.

Many parameters require resource names to be formatted in a particular way. To assist with these names, this class includes a format method for each type of name, and additionally a parse method to extract the individual identifiers contained within names that are returned.

This class can be customized by passing in a custom instance of SubscriptionAdminSettings to create(). For example:

To customize credentials:

 SubscriptionAdminSettings subscriptionAdminSettings =
     SubscriptionAdminSettings.newBuilder()
         .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
         .build();
 SubscriptionAdminClient subscriptionAdminClient =
     SubscriptionAdminClient.create(subscriptionAdminSettings);
 

To customize the endpoint:

 SubscriptionAdminSettings subscriptionAdminSettings =
     SubscriptionAdminSettings.newBuilder().setEndpoint(myEndpoint).build();
 SubscriptionAdminClient subscriptionAdminClient =
     SubscriptionAdminClient.create(subscriptionAdminSettings);
 

Please refer to the GitHub repository's samples for more quickstart code snippets.

Constructs an instance of SubscriptionAdminClient with default settings.

Constructs an instance of SubscriptionAdminClient, using the given settings. The channels are created based on the settings passed in, or defaults for any settings that are not set.

Constructs an instance of SubscriptionAdminClient, using the given stub for making calls. This is for advanced usage - prefer using create(SubscriptionAdminSettings).

Constructs an instance of SubscriptionAdminClient, 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.

Acknowledges the messages associated with the ack_ids in the AcknowledgeRequest. The Pub/Sub system can remove the relevant messages from the subscription.

Acknowledging 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   AcknowledgeRequest request =
       AcknowledgeRequest.newBuilder()
           .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString())
           .addAllAckIds(new ArrayList<String>())
           .build();
   subscriptionAdminClient.acknowledge(request);
 }
 

Deprecated. Use #acknowledge(SubscriptionName, List<String>) instead.

Acknowledges the messages associated with the ack_ids in the AcknowledgeRequest. The Pub/Sub system can remove the relevant messages from the subscription.

Acknowledging 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   List<String> ackIds = new ArrayList<>();
   subscriptionAdminClient.acknowledge(subscription, ackIds);
 }
 

Acknowledges the messages associated with the ack_ids in the AcknowledgeRequest. The Pub/Sub system can remove the relevant messages from the subscription.

Acknowledging 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   List<String> ackIds = new ArrayList<>();
   subscriptionAdminClient.acknowledge(subscription, ackIds);
 }
 

Acknowledges the messages associated with the ack_ids in the AcknowledgeRequest. The Pub/Sub system can remove the relevant messages from the subscription.

Acknowledging 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
   List<String> ackIds = new ArrayList<>();
   subscriptionAdminClient.acknowledge(subscription, ackIds);
 }
 

Acknowledges the messages associated with the ack_ids in the AcknowledgeRequest. The Pub/Sub system can remove the relevant messages from the subscription.

Acknowledging 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   AcknowledgeRequest request =
       AcknowledgeRequest.newBuilder()
           .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString())
           .addAllAckIds(new ArrayList<String>())
           .build();
   ApiFuture<Empty> future = subscriptionAdminClient.acknowledgeCallable().futureCall(request);
   // Do something.
   future.get();
 }
 

Creates a snapshot from the requested subscription. Snapshots are used in Seek 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. 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   CreateSnapshotRequest request =
       CreateSnapshotRequest.newBuilder()
           .setName(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString())
           .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString())
           .putAllLabels(new HashMap

Deprecated. Use Use #createSnapshot(SnapshotName, SubscriptionName) instead.

Creates a snapshot from the requested subscription. Snapshots are used in Seek 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. 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ProjectSnapshotName name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]");
   ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription);
 }
 

Deprecated. Use Use #createSnapshot(SnapshotName, String) instead.

Creates a snapshot from the requested subscription. Snapshots are used in Seek 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. 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ProjectSnapshotName name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]");
   String subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
   Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription);
 }
 

Creates a snapshot from the requested subscription. Snapshots are used in Seek 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. 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   SnapshotName name = SnapshotName.of("[PROJECT]", "[SNAPSHOT]");
   SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription);
 }
 

Creates a snapshot from the requested subscription. Snapshots are used in Seek 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. 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   SnapshotName name = SnapshotName.of("[PROJECT]", "[SNAPSHOT]");
   String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
   Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription);
 }
 

Deprecated. Use Use #createSnapshot(String, SubscriptionName) instead.

Creates a snapshot from the requested subscription. Snapshots are used in Seek 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. 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString();
   ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription);
 }
 

Creates a snapshot from the requested subscription. Snapshots are used in Seek 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. 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String name = SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString();
   SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription);
 }
 

Creates a snapshot from the requested subscription. Snapshots are used in Seek 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. 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String name = SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString();
   String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
   Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription);
 }
 

Creates a snapshot from the requested subscription. Snapshots are used in Seek 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. 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   CreateSnapshotRequest request =
       CreateSnapshotRequest.newBuilder()
           .setName(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString())
           .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString())
           .putAllLabels(new HashMap

Deprecated. Use #createSubscription(SubscriptionName, TopicName, PushConfig, int) instead.

Creates a subscription to a given topic. See the <a href="https://cloud.google.com/pubsub/docs/admin#resource_names">; resource name rules</a>. 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. 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);
 }
 

Deprecated. Use #createSubscription(SubscriptionName, TopicName, PushConfig, int) instead.

Creates a subscription to a given topic. See the resource name rules. 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. 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]");
   TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]");
   PushConfig pushConfig = PushConfig.newBuilder().build();
   int ackDeadlineSeconds = 2135351438;
   Subscription response =
       subscriptionAdminClient.createSubscription(name, topic, pushConfig, ackDeadlineSeconds);
 }
 

Deprecated. Use #createSubscription(SubscriptionName, String, PushConfig, int) instead.

Creates a subscription to a given topic. See the resource name rules. 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. 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]");
   String topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString();
   PushConfig pushConfig = PushConfig.newBuilder().build();
   int ackDeadlineSeconds = 2135351438;
   Subscription response =
       subscriptionAdminClient.createSubscription(name, topic, pushConfig, ackDeadlineSeconds);
 }
 

Creates a subscription to a given topic. See the resource name rules. 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. 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()) {
   Subscription request =
       Subscription.newBuilder()
           .setName(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString())
           .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString())
           .setPushConfig(PushConfig.newBuilder().build())
           .setAckDeadlineSeconds(2135351438)
           .setRetainAckedMessages(true)
           .setMessageRetentionDuration(Duration.newBuilder().build())
           .putAllLabels(new HashMap

Creates a subscription to a given topic. See the resource name rules. 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. 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()) {
   SubscriptionName name = SubscriptionName.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);
 }
 

Creates a subscription to a given topic. See the resource name rules. 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. 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()) {
   SubscriptionName name = SubscriptionName.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);
 }
 

Creates a subscription to a given topic. See the resource name rules. 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. 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()) {
   String name = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
   TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]");
   PushConfig pushConfig = PushConfig.newBuilder().build();
   int ackDeadlineSeconds = 2135351438;
   Subscription response =
       subscriptionAdminClient.createSubscription(name, topic, pushConfig, ackDeadlineSeconds);
 }
 

Creates a subscription to a given topic. See the resource name rules. 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. 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()) {
   String name = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
   String topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString();
   PushConfig pushConfig = PushConfig.newBuilder().build();
   int ackDeadlineSeconds = 2135351438;
   Subscription response =
       subscriptionAdminClient.createSubscription(name, topic, pushConfig, ackDeadlineSeconds);
 }
 

Creates a subscription to a given topic. See the resource name rules. 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. 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()) {
   Subscription request =
       Subscription.newBuilder()
           .setName(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString())
           .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString())
           .setPushConfig(PushConfig.newBuilder().build())
           .setAckDeadlineSeconds(2135351438)
           .setRetainAckedMessages(true)
           .setMessageRetentionDuration(Duration.newBuilder().build())
           .putAllLabels(new HashMap

Removes an existing snapshot. Snapshots are used in Seek 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   DeleteSnapshotRequest request =
       DeleteSnapshotRequest.newBuilder()
           .setSnapshot(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString())
           .build();
   subscriptionAdminClient.deleteSnapshot(request);
 }
 

Deprecated. Use Use #deleteSnapshot(SnapshotName) instead.

Removes an existing snapshot. Snapshots are used in Seek 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]");
   subscriptionAdminClient.deleteSnapshot(snapshot);
 }
 

Removes an existing snapshot. Snapshots are used in Seek 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   SnapshotName snapshot = SnapshotName.of("[PROJECT]", "[SNAPSHOT]");
   subscriptionAdminClient.deleteSnapshot(snapshot);
 }
 

Removes an existing snapshot. Snapshots are used in Seek 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String snapshot = SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString();
   subscriptionAdminClient.deleteSnapshot(snapshot);
 }
 

Removes an existing snapshot. Snapshots are used in Seek 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   DeleteSnapshotRequest request =
       DeleteSnapshotRequest.newBuilder()
           .setSnapshot(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString())
           .build();
   ApiFuture<Empty> future =
       subscriptionAdminClient.deleteSnapshotCallable().futureCall(request);
   // Do something.
   future.get();
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   DeleteSubscriptionRequest request =
       DeleteSubscriptionRequest.newBuilder()
           .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString())
           .build();
   subscriptionAdminClient.deleteSubscription(request);
 }
 

Deprecated. Use #deleteSubscription(SubscriptionName) instead.

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   subscriptionAdminClient.deleteSubscription(subscription);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   subscriptionAdminClient.deleteSubscription(subscription);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
   subscriptionAdminClient.deleteSubscription(subscription);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   DeleteSubscriptionRequest request =
       DeleteSubscriptionRequest.newBuilder()
           .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString())
           .build();
   ApiFuture<Empty> future =
       subscriptionAdminClient.deleteSubscriptionCallable().futureCall(request);
   // Do something.
   future.get();
 }
 

Gets the access control policy for a resource. Returns an empty policyif the resource exists and does not have a policy set.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   GetIamPolicyRequest request =
       GetIamPolicyRequest.newBuilder()
           .setResource(ProjectName.of("[PROJECT]").toString())
           .setOptions(GetPolicyOptions.newBuilder().build())
           .build();
   Policy response = subscriptionAdminClient.getIamPolicy(request);
 }
 

Deprecated. Use #getIamPolicy(GetIamPolicyRequest) instead.

Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String formattedResource = ProjectTopicName.format("[PROJECT]", "[TOPIC]");
   Policy response = subscriptionAdminClient.getIamPolicy(formattedResource);
 }
 

Gets the access control policy for a resource. Returns an empty policyif the resource exists and does not have a policy set.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   GetIamPolicyRequest request =
       GetIamPolicyRequest.newBuilder()
           .setResource(ProjectName.of("[PROJECT]").toString())
           .setOptions(GetPolicyOptions.newBuilder().build())
           .build();
   ApiFuture<Policy> future = subscriptionAdminClient.getIamPolicyCallable().futureCall(request);
   // Do something.
   Policy response = future.get();
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   GetSnapshotRequest request =
       GetSnapshotRequest.newBuilder()
           .setSnapshot(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString())
           .build();
   Snapshot response = subscriptionAdminClient.getSnapshot(request);
 }
 

Deprecated. Use Use #getSnapshot(SnapshotName) instead.

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]");
   Snapshot response = subscriptionAdminClient.getSnapshot(snapshot);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   SnapshotName snapshot = SnapshotName.of("[PROJECT]", "[SNAPSHOT]");
   Snapshot response = subscriptionAdminClient.getSnapshot(snapshot);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String snapshot = SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString();
   Snapshot response = subscriptionAdminClient.getSnapshot(snapshot);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   GetSnapshotRequest request =
       GetSnapshotRequest.newBuilder()
           .setSnapshot(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString())
           .build();
   ApiFuture<Snapshot> future =
       subscriptionAdminClient.getSnapshotCallable().futureCall(request);
   // Do something.
   Snapshot response = future.get();
 }
 

Gets the configuration details of a subscription.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   GetSubscriptionRequest request =
       GetSubscriptionRequest.newBuilder()
           .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString())
           .build();
   Subscription response = subscriptionAdminClient.getSubscription(request);
 }
 

Deprecated. Use #getSubscription(SubscriptionName) instead.

Gets the configuration details of a subscription.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   Subscription response = subscriptionAdminClient.getSubscription(subscription);
 }
 

Gets the configuration details of a subscription.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   Subscription response = subscriptionAdminClient.getSubscription(subscription);
 }
 

Gets the configuration details of a subscription.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
   Subscription response = subscriptionAdminClient.getSubscription(subscription);
 }
 

Gets the configuration details of a subscription.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   GetSubscriptionRequest request =
       GetSubscriptionRequest.newBuilder()
           .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString())
           .build();
   ApiFuture<Subscription> future =
       subscriptionAdminClient.getSubscriptionCallable().futureCall(request);
   // Do something.
   Subscription response = future.get();
 }
 

Lists the existing snapshots. Snapshots are used in Seek 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ListSnapshotsRequest request =
       ListSnapshotsRequest.newBuilder()
           .setProject(ProjectName.of("[PROJECT]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   for (Snapshot element : subscriptionAdminClient.listSnapshots(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Lists the existing snapshots. Snapshots are used in Seek 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ProjectName project = ProjectName.of("[PROJECT]");
   for (Snapshot element : subscriptionAdminClient.listSnapshots(project).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Lists the existing snapshots. Snapshots are used in Seek 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String project = ProjectName.of("[PROJECT]").toString();
   for (Snapshot element : subscriptionAdminClient.listSnapshots(project).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Lists the existing snapshots. Snapshots are used in Seek 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ListSnapshotsRequest request =
       ListSnapshotsRequest.newBuilder()
           .setProject(ProjectName.of("[PROJECT]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   while (true) {
     ListSnapshotsResponse response =
         subscriptionAdminClient.listSnapshotsCallable().call(request);
     for (Snapshot element : response.getResponsesList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
 

Lists the existing snapshots. Snapshots are used in Seek 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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ListSnapshotsRequest request =
       ListSnapshotsRequest.newBuilder()
           .setProject(ProjectName.of("[PROJECT]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   ApiFuture<Snapshot> future =
       subscriptionAdminClient.listSnapshotsPagedCallable().futureCall(request);
   // Do something.
   for (Snapshot element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Lists matching subscriptions.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ListSubscriptionsRequest request =
       ListSubscriptionsRequest.newBuilder()
           .setProject(ProjectName.of("[PROJECT]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   for (Subscription element : subscriptionAdminClient.listSubscriptions(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Lists matching subscriptions.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ProjectName project = ProjectName.of("[PROJECT]");
   for (Subscription element : subscriptionAdminClient.listSubscriptions(project).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Lists matching subscriptions.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String project = ProjectName.of("[PROJECT]").toString();
   for (Subscription element : subscriptionAdminClient.listSubscriptions(project).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Lists matching subscriptions.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ListSubscriptionsRequest request =
       ListSubscriptionsRequest.newBuilder()
           .setProject(ProjectName.of("[PROJECT]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   while (true) {
     ListSubscriptionsResponse response =
         subscriptionAdminClient.listSubscriptionsCallable().call(request);
     for (Subscription element : response.getResponsesList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }