Reference documentation and code samples for the Cloud Pub/Sub V1 API class Google::Cloud::PubSub::V1::StreamingPullResponse.
Response for the StreamingPull
method. This response is used to stream
messages from the server to the client.
Inherits
- Object
Extended By
- Google::Protobuf::MessageExts::ClassMethods
Includes
- Google::Protobuf::MessageExts
Methods
#acknowledge_confirmation
def acknowledge_confirmation() -> ::Google::Cloud::PubSub::V1::StreamingPullResponse::AcknowledgeConfirmation
Returns
-
(::Google::Cloud::PubSub::V1::StreamingPullResponse::AcknowledgeConfirmation) — Optional. This field will only be set if
enable_exactly_once_delivery
is set totrue
.
#acknowledge_confirmation=
def acknowledge_confirmation=(value) -> ::Google::Cloud::PubSub::V1::StreamingPullResponse::AcknowledgeConfirmation
Parameter
-
value (::Google::Cloud::PubSub::V1::StreamingPullResponse::AcknowledgeConfirmation) — Optional. This field will only be set if
enable_exactly_once_delivery
is set totrue
.
Returns
-
(::Google::Cloud::PubSub::V1::StreamingPullResponse::AcknowledgeConfirmation) — Optional. This field will only be set if
enable_exactly_once_delivery
is set totrue
.
#modify_ack_deadline_confirmation
def modify_ack_deadline_confirmation() -> ::Google::Cloud::PubSub::V1::StreamingPullResponse::ModifyAckDeadlineConfirmation
Returns
-
(::Google::Cloud::PubSub::V1::StreamingPullResponse::ModifyAckDeadlineConfirmation) — Optional. This field will only be set if
enable_exactly_once_delivery
is set totrue
.
#modify_ack_deadline_confirmation=
def modify_ack_deadline_confirmation=(value) -> ::Google::Cloud::PubSub::V1::StreamingPullResponse::ModifyAckDeadlineConfirmation
Parameter
-
value (::Google::Cloud::PubSub::V1::StreamingPullResponse::ModifyAckDeadlineConfirmation) — Optional. This field will only be set if
enable_exactly_once_delivery
is set totrue
.
Returns
-
(::Google::Cloud::PubSub::V1::StreamingPullResponse::ModifyAckDeadlineConfirmation) — Optional. This field will only be set if
enable_exactly_once_delivery
is set totrue
.
#received_messages
def received_messages() -> ::Array<::Google::Cloud::PubSub::V1::ReceivedMessage>
Returns
- (::Array<::Google::Cloud::PubSub::V1::ReceivedMessage>) — Optional. Received Pub/Sub messages. This will not be empty.
#received_messages=
def received_messages=(value) -> ::Array<::Google::Cloud::PubSub::V1::ReceivedMessage>
Parameter
- value (::Array<::Google::Cloud::PubSub::V1::ReceivedMessage>) — Optional. Received Pub/Sub messages. This will not be empty.
Returns
- (::Array<::Google::Cloud::PubSub::V1::ReceivedMessage>) — Optional. Received Pub/Sub messages. This will not be empty.
#subscription_properties
def subscription_properties() -> ::Google::Cloud::PubSub::V1::StreamingPullResponse::SubscriptionProperties
Returns
- (::Google::Cloud::PubSub::V1::StreamingPullResponse::SubscriptionProperties) — Optional. Properties associated with this subscription.
#subscription_properties=
def subscription_properties=(value) -> ::Google::Cloud::PubSub::V1::StreamingPullResponse::SubscriptionProperties
Parameter
- value (::Google::Cloud::PubSub::V1::StreamingPullResponse::SubscriptionProperties) — Optional. Properties associated with this subscription.
Returns
- (::Google::Cloud::PubSub::V1::StreamingPullResponse::SubscriptionProperties) — Optional. Properties associated with this subscription.