s parameter is 0, a default value of 10 seconds is used.
* For push delivery, this value is also used to set the request timeout for
* the call to the push endpoint.
* If the subscriber never acknowledges the message, the Pub/Sub
* system will eventually redeliver the message.
*
* Generated from protobuf field int32 ack_deadline_seconds = 5;
* @return int
*/
public function getAckDeadlineSeconds()
{
return $this->ack_deadline_seconds;
}
/**
* This value is the maximum time after a subscriber receives a message
* before the subscriber should acknowledge the message. After message
* delivery but before the ack deadline expires and before the message is
* acknowledged, it is an outstanding message and will not be delivered
* again during that time (on a best-effort basis).
* For pull subscriptions, this value is used as the initial value for the ack
* deadline. To override this value for a given message, call
* `ModifyAckDeadline` with the corresponding `ack_id` if using
* pull.
* The minimum custom deadline you can specify is 10 seconds.
* The maximum custom deadline you can specify is 600 seconds (10 minutes).
* If this parameter is 0, a default value of 10 seconds is used.
* For push delivery, this value is also used to set the request timeout for
* the call to the push endpoint.
* If the subscriber never acknowledges the message, the Pub/Sub
* system will eventually redeliver the message.
*
* Generated from protobuf field int32 ack_deadline_seconds = 5;
* @param int $var
* @return $this
*/
public function setAckDeadlineSeconds($var)
{
GPBUtil::checkInt32($var);
$this->ack_deadline_seconds = $var;
return $this;
}
/**
* Indicates whether to retain acknowledged messages. If true, then
* messages are not expunged from the subscription's backlog, even if they are
* acknowledged, until they fall out of the `message_retention_duration`
* window.
*
* Generated from protobuf field bool retain_acked_messages = 7;
* @return bool
*/
public function getRetainAckedMessages()
{
return $this->retain_acked_messages;
}
/**
* Indicates whether to retain acknowledged messages. If true, then
* messages are not expunged from the subscription's backlog, even if they are
* acknowledged, until they fall out of the `message_retention_duration`
* window.
*
* Generated from protobuf field bool retain_acked_messages = 7;
* @param bool $var
* @return $this
*/
public function setRetainAckedMessages($var)
{
GPBUtil::checkBool($var);
$this->retain_acked_messages = $var;
return $this;
}
/**
* How long to retain unacknowledged messages in the subscription's backlog,
* from the moment a message is published.
* If `retain_acked_messages` is true, then this also configures the retention
* of acknowledged messages, and thus configures how far back in time a `Seek`
* can be done. Defaults to 7 days. Cannot be more than 7 days or less than 10
* minutes.
*
* Generated from protobuf field .google.protobuf.Duration message_retention_duration = 8;
* @return \Google\Protobuf\Duration
*/
public function getMessageRetentionDuration()
{
return $this->message_retention_duration;
}
/**
* How long to retain unacknowledged messages in the subscription's backlog,
* from the moment a message is published.
* If `retain_acked_messages` is true, then this also configures the retention
* of acknowledged messages, and thus configures how far back in time a `Seek`
* can be done. Defaults to 7 days. Cannot be more than 7 days or less than 10
* minutes.
*
* Generated from protobuf field .google.protobuf.Duration message_retention_duration = 8;
* @param \Google\Protobuf\Duration $var
* @return $this
*/
public function setMessageRetentionDuration($var)
{
GPBUtil::checkMessage($var, \Google\Protobuf\Duration::class);
$this->message_retention_duration = $var;
return $this;
}
/**
* User labels.
*
* Generated from protobuf field map labels = 9;
* @return \Google\Protobuf\Internal\MapField
*/
public function getLabels()
{
return $this->labels;
}
/**
* User labels.
*
* Generated from protobuf field map labels = 9;
* @param array|\Google\Protobuf\Internal\MapField $var
* @return $this
*/
public function setLabels($var)
{
$arr = GPBUtil::checkMapField($var, \Google\Protobuf\Internal\GPBType::STRING, \Google\Protobuf\Internal\GPBType::STRING);
$this->labels = $arr;
return $this;
}
}