Sha256: 9da9c0da734eda574896320cb964f723db1e2e85eea6e4572b20dbfd7333cc3d
Contents?: true
Size: 900 Bytes
Versions: 14
Compression:
Stored size: 900 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
14 entries across 14 versions & 1 rubygems