From 1894e735afa6b8e59a89e6bac608c382c7633c74 Mon Sep 17 00:00:00 2001 From: Stephen Weinberg Date: Tue, 16 Oct 2018 12:09:43 -0400 Subject: [PATCH] setMaxInboundMessageSize in Pubsub exmaple Pub/Sub may return up to 20MB of data from a single pull request. The default of 4MB is not enough for even one message of maximum size (10MB). --- .../examples/pubsub/snippets/SubscriberSnippets.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java b/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java index b31862a690b5..7bd756e81bff 100644 --- a/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java +++ b/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java @@ -192,7 +192,14 @@ static List createSubscriberWithSyncPull( String projectId, String subscriptionId, int numOfMessages) throws Exception { // [START pubsub_subscriber_sync_pull] SubscriberStubSettings subscriberStubSettings = - SubscriberStubSettings.newBuilder().build(); + SubscriberStubSettings.newBuilder() + .setTransportChannelProvider( + SubscriberStubSettings.defaultGrpcTransportProviderBuilder() + .setMaxInboundMessageSize(20<<20) // 20MB + .build() + ) + .build(); + try (SubscriberStub subscriber = GrpcSubscriberStub.create(subscriberStubSettings)) { // String projectId = "my-project-id"; // String subscriptionId = "my-subscription-id";