Skip to content

Commit c5c95be

Browse files
Revert "feat: ensure large message batches can be received by subscribers (#1133)" (#1135)
This reverts commit 3276d47.
1 parent 3276d47 commit c5c95be

File tree

1 file changed

+0
-5
lines changed
  • google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/internal/wire

1 file changed

+0
-5
lines changed

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/internal/wire/ServiceClients.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -37,10 +37,6 @@ public final class ServiceClients {
3737
private static final int CLIENT_POOL_SIZE =
3838
Integer.parseInt(System.getProperty("PUBSUB_LITE_CHANNELS_PER_CLIENT", "10"));
3939

40-
// Set maximum inbound message size to 20 MiB to match Cloud Pub/Sub and ensure at least 1 10 MiB
41-
// message can be received in a subscribe batch.
42-
private static final int MAX_INBOUND_MESSAGE_SIZE = 20 * 1024 * 1024;
43-
4440
private ServiceClients() {}
4541

4642
private static TransportChannelProvider getTransportChannelProvider() {
@@ -51,7 +47,6 @@ private static TransportChannelProvider getTransportChannelProvider() {
5147
.setKeepAliveTimeout(Duration.ofMinutes(1))
5248
.setPoolSize(CLIENT_POOL_SIZE)
5349
.setExecutor(SystemExecutors.getFuturesExecutor())
54-
.setMaxInboundMessageSize(MAX_INBOUND_MESSAGE_SIZE)
5550
.build();
5651
}
5752

0 commit comments

Comments
 (0)