32 use Google\Service\Pubsub\Subscription;  alias
50    * from the subscription. Acknowledging a message whose ack deadline has expired
55    * @param string $subscription Required. The subscription whose message is being
61   public function acknowledge($subscription, AcknowledgeRequest $postBody, $optParams = [])  argument
63     $params = ['subscription' => $subscription, 'postBody' => $postBody];
68    * Creates a subscription to a given topic. See the [resource name rules]
70    * subscription already exists, returns `ALREADY_EXISTS`. If the corresponding
72    * request, the server will assign a random name for this subscription on the
75    * name is populated in the returned Subscription object. Note that for REST API
78    * @param string $name Required. The name of the subscription. It must have the
79    * format `"projects/{project}/subscriptions/{subscription}"`. `{subscription}`
84    * @param Subscription $postBody
86    * @return Subscription
88   public function create($name, Subscription $postBody, $optParams = [])
92     return $this->call('create', [$params], Subscription::class);
95    * Deletes an existing subscription. All messages retained in the subscription
97    * `NOT_FOUND`. After a subscription is deleted, a new one may be created with
98    * the same name, but the new one has no association with the old subscription
101    * @param string $subscription Required. The subscription to delete. Format is
106   public function delete($subscription, $optParams = [])  argument
108     $params = ['subscription' => $subscription];
113    * Detaches a subscription from this topic. All messages retained in the
114    * subscription are dropped. Subsequent `Pull` and `StreamingPull` requests will
115    * return FAILED_PRECONDITION. If the subscription is a push subscription,
118    * @param string $subscription Required. The subscription to detach. Format is
119    * `projects/{project}/subscriptions/{subscription}`.
123   public function detach($subscription, $optParams = [])  argument
125     $params = ['subscription' => $subscription];
130    * Gets the configuration details of a subscription. (subscriptions.get)
132    * @param string $subscription Required. The name of the subscription to get.
135    * @return Subscription
137   public function get($subscription, $optParams = [])  argument
139     $params = ['subscription' => $subscription];
141     return $this->call('get', [$params], Subscription::class);
196    * interrupted. Note that this does not modify the subscription-level
200    * @param string $subscription Required. The name of the subscription. Format is
206 …public function modifyAckDeadline($subscription, ModifyAckDeadlineRequest $postBody, $optParams = …  argument
208     $params = ['subscription' => $subscription, 'postBody' => $postBody];
213    * Modifies the `PushConfig` for a specified subscription. This may be used to
214    * change a push subscription to a pull one (signified by an empty `PushConfig`)
216    * subscription. Messages will accumulate for delivery continuously through the
220    * @param string $subscription Required. The name of the subscription. Format is
226 …public function modifyPushConfig($subscription, ModifyPushConfigRequest $postBody, $optParams = [])  argument
228     $params = ['subscription' => $subscription, 'postBody' => $postBody];
233    * Updates an existing subscription. Note that certain properties of a
234    * subscription, such as its topic, are not modifiable. (subscriptions.patch)
236    * @param string $name Required. The name of the subscription. It must have the
237    * format `"projects/{project}/subscriptions/{subscription}"`. `{subscription}`
244    * @return Subscription
250     return $this->call('patch', [$params], Subscription::class);
254    * are too many concurrent pull requests pending for the given subscription.
257    * @param string $subscription Required. The subscription from which messages
263   public function pull($subscription, PullRequest $postBody, $optParams = [])  argument
265     $params = ['subscription' => $subscription, 'postBody' => $postBody];
270    * Seeks an existing subscription to a point in time or to a given snapshot,
274    * acknowledgment state of messages in an existing subscription to the state
275    * captured by a snapshot. Note that both the subscription and the snapshot must
278    * @param string $subscription Required. The subscription to affect.
283   public function seek($subscription, SeekRequest $postBody, $optParams = [])  argument
285     $params = ['subscription' => $subscription, 'postBody' => $postBody];