Skip to content

Commit 2480af0

Browse files
stephenmwJesseLovelace
authored andcommitted
---
yaml --- r: 10221 b: refs/heads/master c: 7e60bc8 h: refs/heads/master i: 10219: f2df71e
1 parent bbf3e48 commit 2480af0

2 files changed

Lines changed: 9 additions & 2 deletions

File tree

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
---
2-
refs/heads/master: db9d244abec3be1f7aee4e3fcedc497fc81b9d71
2+
refs/heads/master: 7e60bc881311334d0d59bab3acfb53e01766fdc5
33
refs/heads/travis: 47e4fee4fd5af9b2a8ce46f23c72ec95f9b195b2
44
refs/heads/gh-pages: 9557e74bb0c6b2918b40660d6d1b35f742e5e727
55
refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444

trunk/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -192,7 +192,14 @@ static List<ReceivedMessage> createSubscriberWithSyncPull(
192192
String projectId, String subscriptionId, int numOfMessages) throws Exception {
193193
// [START pubsub_subscriber_sync_pull]
194194
SubscriberStubSettings subscriberStubSettings =
195-
SubscriberStubSettings.newBuilder().build();
195+
SubscriberStubSettings.newBuilder()
196+
.setTransportChannelProvider(
197+
SubscriberStubSettings.defaultGrpcTransportProviderBuilder()
198+
.setMaxInboundMessageSize(20<<20) // 20MB
199+
.build()
200+
)
201+
.build();
202+
196203
try (SubscriberStub subscriber = GrpcSubscriberStub.create(subscriberStubSettings)) {
197204
// String projectId = "my-project-id";
198205
// String subscriptionId = "my-subscription-id";

0 commit comments

Comments
 (0)