Sha256: 2ed6811ae41950beb80aa9dc5ef6689782c410b590b54238c9b82ee1a40cd496
Contents?: true
Size: 903 Bytes
Versions: 27
Compression:
Stored size: 903 Bytes
Contents
module Fog
module Google
class Pubsub
class Real
# Acknowledges a message received from a subscription.
#
# @see https://cloud.google.com/pubsub/reference/rest/v1/projects.subscriptions/acknowledge
def acknowledge_subscription(subscription, ack_ids)
# Previous behavior allowed passing a single ack_id without being wrapped in an Array,
# this is for backwards compatibility.
unless ack_ids.is_a?(Array)
ack_ids = [ack_ids]
end
ack_request = ::Google::Apis::PubsubV1::AcknowledgeRequest.new(
:ack_ids => ack_ids
)
@pubsub.acknowledge_subscription(subscription, ack_request)
end
end
class Mock
def acknowledge_subscription(_subscription, _ack_ids)
raise Fog::Errors::MockNotImplemented
end
end
end
end
end
Version data entries
27 entries across 27 versions & 2 rubygems