lib/google/cloud/pubsub/v1/subscriber_client.rb in google-cloud-pubsub-0.23.2 vs lib/google/cloud/pubsub/v1/subscriber_client.rb in google-cloud-pubsub-0.24.0
- old
+ new
@@ -1,12 +1,12 @@
-# Copyright 2016 Google Inc. All rights reserved.
+# Copyright 2017, Google Inc. All rights reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
-# http://www.apache.org/licenses/LICENSE-2.0
+# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
@@ -24,10 +24,11 @@
require "json"
require "pathname"
require "google/gax"
+
require "google/iam/v1/iam_policy_pb"
require "google/pubsub/v1/pubsub_pb"
module Google
module Cloud
@@ -671,19 +672,19 @@
# subscription.
#
# @param subscription [String]
# The subscription from which messages should be pulled.
# Format is +projects/{project}/subscriptions/{sub}+.
+ # @param max_messages [Integer]
+ # The maximum number of messages returned for this request. The Pub/Sub
+ # system may return fewer than the number specified.
# @param return_immediately [true, false]
# If this field set to true, the system will respond immediately even if
# it there are no messages available to return in the +Pull+ response.
# Otherwise, the system may wait (for a bounded amount of time) until at
# least one message is available, rather than returning no messages. The
# client may cancel the request if it does not wish to wait any longer for
# the response.
- # @param max_messages [Integer]
- # The maximum number of messages returned for this request. The Pub/Sub
- # system may return fewer than the number specified.
# @param options [Google::Gax::CallOptions]
# Overrides the default settings for this call, e.g, timeout,
# retries, etc.
# @return [Google::Pubsub::V1::PullResponse]
# @raise [Google::Gax::GaxError] if the RPC is aborted.