diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PollingSubscriberConnection.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PollingSubscriberConnection.java
index 3ee825efff80..dfa43052cd2a 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PollingSubscriberConnection.java
+++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PollingSubscriberConnection.java
@@ -23,6 +23,7 @@
import com.google.cloud.pubsub.spi.v1.MessageDispatcher.AckProcessor;
import com.google.cloud.pubsub.spi.v1.MessageDispatcher.PendingModifyAckDeadline;
import com.google.common.collect.Lists;
+import com.google.common.primitives.Ints;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
@@ -70,7 +71,7 @@ public PollingSubscriberConnection(
Distribution ackLatencyDistribution,
Channel channel,
FlowController flowController,
- @Nullable Integer maxDesiredPulledMessages,
+ @Nullable Long maxDesiredPulledMessages,
ScheduledExecutorService executor,
@Nullable ScheduledExecutorService alarmsExecutor,
ApiClock clock) {
@@ -90,7 +91,9 @@ public PollingSubscriberConnection(
clock);
messageDispatcher.setMessageDeadlineSeconds(Subscriber.MIN_ACK_DEADLINE_SECONDS);
this.maxDesiredPulledMessages =
- maxDesiredPulledMessages != null ? maxDesiredPulledMessages : DEFAULT_MAX_MESSAGES;
+ maxDesiredPulledMessages != null
+ ? Ints.saturatedCast(maxDesiredPulledMessages)
+ : DEFAULT_MAX_MESSAGES;
}
@Override
diff --git a/pom.xml b/pom.xml
index e04e89dca7f7..3c8b4cdb5e96 100644
--- a/pom.xml
+++ b/pom.xml
@@ -129,9 +129,10 @@
google-cloud
1.21.0
+
1.1.0
- 1.0.0
- 0.16.0
+ 1.1.0
+ 0.17.0
0.1.9
0.6.1
1.2.0