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;
     }
   }
 }
 

Lists matching subscriptions.

Sample code:

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

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:

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

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:

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

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:

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

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:

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

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:

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

Deprecated. Use #modifyPushConfig(SubscriptionName, PushConfig) instead.

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   PushConfig pushConfig = PushConfig.newBuilder().build();
   subscriptionAdminClient.modifyPushConfig(subscription, pushConfig);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   PushConfig pushConfig = PushConfig.newBuilder().build();
   subscriptionAdminClient.modifyPushConfig(subscription, pushConfig);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
   PushConfig pushConfig = PushConfig.newBuilder().build();
   subscriptionAdminClient.modifyPushConfig(subscription, pushConfig);
 }
 

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:

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

Deprecated. Use #pull(SubscriptionName, int) instead.

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   int maxMessages = 496131527;
   PullResponse response = subscriptionAdminClient.pull(subscription, maxMessages);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   PullRequest request =
       PullRequest.newBuilder()
           .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString())
           .setReturnImmediately(true)
           .setMaxMessages(496131527)
           .build();
   PullResponse response = subscriptionAdminClient.pull(request);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   boolean returnImmediately = true;
   int maxMessages = 496131527;
   PullResponse response =
       subscriptionAdminClient.pull(subscription, returnImmediately, maxMessages);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]");
   int maxMessages = 496131527;
   PullResponse response = subscriptionAdminClient.pull(subscription, maxMessages);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
   boolean returnImmediately = true;
   int maxMessages = 496131527;
   PullResponse response =
       subscriptionAdminClient.pull(subscription, returnImmediately, maxMessages);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString();
   int maxMessages = 496131527;
   PullResponse response = subscriptionAdminClient.pull(subscription, maxMessages);
 }
 

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:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   PullRequest request =
       PullRequest.newBuilder()
           .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString())
           .setReturnImmediately(true)
           .setMaxMessages(496131527)
           .build();
   ApiFuture

Seeks an existing subscription to a point in time or to a given snapshot, whichever is provided in the request. 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. Note that both the subscription and the snapshot must be on the same topic.

Sample code:

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

Seeks an existing subscription to a point in time or to a given snapshot, whichever is provided in the request. 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. Note that both the subscription and the snapshot must be on the same topic.

Sample code:

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

Sets the access control policy on the specified resource. Replacesany existing policy.

Can return NOT_FOUND, INVALID_ARGUMENT, and PERMISSION_DENIEDerrors.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   SetIamPolicyRequest request =
       SetIamPolicyRequest.newBuilder()
           .setResource(ProjectName.of("[PROJECT]").toString())
           .setPolicy(Policy.newBuilder().build())
           .build();
   Policy response = subscriptionAdminClient.setIamPolicy(request);
 }
 

Deprecated. Use #setIamPolicy(SetIamPolicyRequest) instead.

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);
 }
 

Sets the access control policy on the specified resource. Replacesany existing policy.

Can return NOT_FOUND, INVALID_ARGUMENT, and PERMISSION_DENIEDerrors.

Sample code:

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

Establishes a stream with the server, which sends messages down to the client. The client streams acknowledgements and ack deadline modifications back to the server. The server will close the stream and return the status on any error. The server may close the stream with status UNAVAILABLE to reassign server-side resources, in which case, the client should re-establish the stream. Flow control can be achieved by configuring the underlying RPC channel.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   BidiStream

Returns permissions that a caller has on the specified resource. If theresource does not exist, this will return an empty set ofpermissions, not a NOT_FOUND error.

Note: This operation is designed to be used for buildingpermission-aware UIs and command-line tools, not for authorizationchecking. This operation may "fail open" without warning.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   TestIamPermissionsRequest request =
       TestIamPermissionsRequest.newBuilder()
           .setResource(ProjectName.of("[PROJECT]").toString())
           .addAllPermissions(new ArrayList<String>())
           .build();
   TestIamPermissionsResponse response = subscriptionAdminClient.testIamPermissions(request);
 }
 

Deprecated. Use #testIamPermissions(TestIamPermissionsRequest) instead.

Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.

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);
 }
 

Returns permissions that a caller has on the specified resource. If theresource does not exist, this will return an empty set ofpermissions, not a NOT_FOUND error.

Note: This operation is designed to be used for buildingpermission-aware UIs and command-line tools, not for authorizationchecking. This operation may "fail open" without warning.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   TestIamPermissionsRequest request =
       TestIamPermissionsRequest.newBuilder()
           .setResource(ProjectName.of("[PROJECT]").toString())
           .addAllPermissions(new ArrayList<String>())
           .build();
   ApiFuture

Updates an existing 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()) {
   UpdateSnapshotRequest request =
       UpdateSnapshotRequest.newBuilder()
           .setSnapshot(Snapshot.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .build();
   Snapshot response = subscriptionAdminClient.updateSnapshot(request);
 }
 

Updates an existing 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()) {
   UpdateSnapshotRequest request =
       UpdateSnapshotRequest.newBuilder()
           .setSnapshot(Snapshot.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .build();
   ApiFuture<Snapshot> future =
       subscriptionAdminClient.updateSnapshotCallable().futureCall(request);
   // Do something.
   Snapshot response = future.get();
 }
 

Updates an existing subscription. Note that certain properties of a subscription, such as its topic, are not modifiable.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   UpdateSubscriptionRequest request =
       UpdateSubscriptionRequest.newBuilder()
           .setSubscription(Subscription.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .build();
   Subscription response = subscriptionAdminClient.updateSubscription(request);
 }
 

Updates an existing subscription. Note that certain properties of a subscription, such as its topic, are not modifiable.

Sample code:

 try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
   UpdateSubscriptionRequest request =
       UpdateSubscriptionRequest.newBuilder()
           .setSubscription(Subscription.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .build();
   ApiFuture<Subscription> future =
       subscriptionAdminClient.updateSubscriptionCallable().futureCall(request);
   // Do something.
   Subscription response = future.get();
 }