com.google.api.services.pubsub

Class Pubsub.Projects.Subscriptions

java.lang.Object

com.google.api.services.pubsub.Pubsub.Projects.Subscriptions

Enclosing class:

Pubsub.Projects

public class Pubsub.Projects.Subscriptions
extends java.lang.Object

The "subscriptions" collection of methods.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	Pubsub.Projects.Subscriptions.Acknowledge
class	Pubsub.Projects.Subscriptions.Create
class	Pubsub.Projects.Subscriptions.Delete
class	Pubsub.Projects.Subscriptions.Get
class	Pubsub.Projects.Subscriptions.GetIamPolicy
class	Pubsub.Projects.Subscriptions.List
class	Pubsub.Projects.Subscriptions.ModifyAckDeadline
class	Pubsub.Projects.Subscriptions.ModifyPushConfig
class	Pubsub.Projects.Subscriptions.Pull
class	Pubsub.Projects.Subscriptions.SetIamPolicy
class	Pubsub.Projects.Subscriptions.TestIamPermissions

Constructor Summary

Constructors

Constructor and Description
Pubsub.Projects.Subscriptions()

Method Summary

Methods

Modifier and Type	Method and Description
Pubsub.Projects.Subscriptions.Acknowledge	acknowledge(java.lang.String subscription, AcknowledgeRequest content) Acknowledges the messages associated with the `ack_ids` in the `AcknowledgeRequest`.
Pubsub.Projects.Subscriptions.Create	create(java.lang.String name, Subscription content) Creates a subscription to a given topic for a given subscriber.
Pubsub.Projects.Subscriptions.Delete	delete(java.lang.String subscription) Deletes an existing subscription.
Pubsub.Projects.Subscriptions.Get	get(java.lang.String subscription) Gets the configuration details of a subscription.
Pubsub.Projects.Subscriptions.GetIamPolicy	getIamPolicy(java.lang.String resource) Gets the access control policy for a `resource`.
Pubsub.Projects.Subscriptions.List	list(java.lang.String project) Lists matching subscriptions.
Pubsub.Projects.Subscriptions.ModifyAckDeadline	modifyAckDeadline(java.lang.String subscription, ModifyAckDeadlineRequest content) Modifies the ack deadline for a specific message.
Pubsub.Projects.Subscriptions.ModifyPushConfig	modifyPushConfig(java.lang.String subscription, ModifyPushConfigRequest content) Modifies the `PushConfig` for a specified subscription.
Pubsub.Projects.Subscriptions.Pull	pull(java.lang.String subscription, PullRequest content) Pulls messages from the server.
Pubsub.Projects.Subscriptions.SetIamPolicy	setIamPolicy(java.lang.String resource, SetIamPolicyRequest content) Sets the access control policy on the specified resource.
Pubsub.Projects.Subscriptions.TestIamPermissions	testIamPermissions(java.lang.String resource, TestIamPermissionsRequest content) Returns permissions that a caller has on the specified resource.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Pubsub.Projects.Subscriptions

public Pubsub.Projects.Subscriptions()

Method Detail

acknowledge

public Pubsub.Projects.Subscriptions.Acknowledge acknowledge(java.lang.String subscription,
                                                    AcknowledgeRequest content)
                                                      throws java.io.IOException

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. Create a request for the method "subscriptions.acknowledge". This request holds the parameters needed by the pubsub server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

subscription - The subscription whose message is being acknowledged.

content - the AcknowledgeRequest

Returns:

the request

Throws:

java.io.IOException

create

public Pubsub.Projects.Subscriptions.Create create(java.lang.String name,
                                          Subscription content)
                                            throws java.io.IOException

Creates a subscription to a given topic for a given subscriber. 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. Create a request for the method "subscriptions.create". This request holds the parameters needed by the pubsub server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

name - The name of the subscription. It must have the format `"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must start with a letter, and contain only letters (`[A-Za-z]`), numbers (`[0-9]`), dashes (`-`), underscores (`_`), periods (`.`), tildes (`~`), plus (`+`) or percent signs (`%`). It must be between 3 and 255 characters in length, and it must not start with `"goog"`.

content - the Subscription

Returns:

the request

Throws:

java.io.IOException

delete

public Pubsub.Projects.Subscriptions.Delete delete(java.lang.String subscription)
                                            throws java.io.IOException

Deletes an existing subscription. All pending messages 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. Create a request for the method "subscriptions.delete". This request holds the parameters needed by the pubsub server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

subscription - The subscription to delete.

Returns:

the request

Throws:

java.io.IOException

get

public Pubsub.Projects.Subscriptions.Get get(java.lang.String subscription)
                                      throws java.io.IOException

Gets the configuration details of a subscription. Create a request for the method "subscriptions.get". This request holds the parameters needed by the pubsub server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

subscription - The name of the subscription to get.

Returns:

the request

Throws:

java.io.IOException

getIamPolicy

public Pubsub.Projects.Subscriptions.GetIamPolicy getIamPolicy(java.lang.String resource)
                                                        throws java.io.IOException

Gets the access control policy for a `resource`. Is empty if the policy or the resource does not exist. Create a request for the method "subscriptions.getIamPolicy". This request holds the parameters needed by the pubsub server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

resource - REQUIRED: The resource for which policy is being requested. `resource` is usually specified as a path, such as, `projects/{project}/zones/{zone}/disks/{disk}`. The format for the path specified in this value is resource specific and is specified in the documentation for the respective GetIamPolicy rpc.

Returns:

the request

Throws:

java.io.IOException

list

public Pubsub.Projects.Subscriptions.List list(java.lang.String project)
                                        throws java.io.IOException

Lists matching subscriptions. Create a request for the method "subscriptions.list". This request holds the parameters needed by the pubsub server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

project - The name of the cloud project that subscriptions belong to.

Returns:

the request

Throws:

java.io.IOException

modifyAckDeadline

public Pubsub.Projects.Subscriptions.ModifyAckDeadline modifyAckDeadline(java.lang.String subscription,
                                                                ModifyAckDeadlineRequest content)
                                                                  throws java.io.IOException

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. Create a request for the method "subscriptions.modifyAckDeadline". This request holds the parameters needed by the pubsub server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

subscription - The name of the subscription.

content - the ModifyAckDeadlineRequest

Returns:

the request

Throws:

java.io.IOException

modifyPushConfig

public Pubsub.Projects.Subscriptions.ModifyPushConfig modifyPushConfig(java.lang.String subscription,
                                                              ModifyPushConfigRequest content)
                                                                throws java.io.IOException

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`. Create a request for the method "subscriptions.modifyPushConfig". This request holds the parameters needed by the pubsub server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

subscription - The name of the subscription.

content - the ModifyPushConfigRequest

Returns:

the request

Throws:

java.io.IOException

pull

public Pubsub.Projects.Subscriptions.Pull pull(java.lang.String subscription,
                                      PullRequest content)
                                        throws java.io.IOException

Pulls messages from the server. Returns an empty list if there are no messages available in the backlog. The server may return `UNAVAILABLE` if there are too many concurrent pull requests pending for the given subscription. Create a request for the method "subscriptions.pull". This request holds the parameters needed by the pubsub server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

subscription - The subscription from which messages should be pulled.

content - the PullRequest

Returns:

the request

Throws:

java.io.IOException

setIamPolicy

public Pubsub.Projects.Subscriptions.SetIamPolicy setIamPolicy(java.lang.String resource,
                                                      SetIamPolicyRequest content)
                                                        throws java.io.IOException

Sets the access control policy on the specified resource. Replaces any existing policy. Create a request for the method "subscriptions.setIamPolicy". This request holds the parameters needed by the pubsub server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

resource - REQUIRED: The resource for which policy is being specified. `resource` is usually specified as a path, such as, `projects/{project}/zones/{zone}/disks/{disk}`. The format for the path specified in this value is resource specific and is specified in the documentation for the respective SetIamPolicy rpc.

content - the SetIamPolicyRequest

Returns:

the request

Throws:

java.io.IOException

testIamPermissions

public Pubsub.Projects.Subscriptions.TestIamPermissions testIamPermissions(java.lang.String resource,
                                                                  TestIamPermissionsRequest content)
                                                                    throws java.io.IOException

Returns permissions that a caller has on the specified resource. Create a request for the method "subscriptions.testIamPermissions". This request holds the parameters needed by the pubsub server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

resource - REQUIRED: The resource for which policy detail is being requested. `resource` is usually specified as a path, such as, `projects/{project}/zones/{zone}/disks/{disk}`. The format for the path specified in this value is resource specific and is specified in the documentation for the respective TestIamPermissions rpc.

content - the TestIamPermissionsRequest

Returns:

the request

Throws:

java.io.IOException