digital-asset/daml
1
1
Fork 0
mirror of https://github.com/digital-asset/daml.git synced 2024-09-19 16:57:40 +03:00
Code Issues Projects Releases Wiki Activity

Raise the default size of inbound message size in java bindings (#19325)

Browse Source
This commit is contained in:
mziolekda 2024-06-03 20:11:10 +02:00 committed by GitHub
parent 798f7d8bf4
commit 632d114191
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
sdk/language-support/java/bindings-rxjava/src/main/java/com/daml/ledger/rxjava/DamlLedgerClient.java
View File

@ -45,6 +45,8 @@ public final class DamlLedgerClient implements LedgerClient {
private Optional<String> accessToken = Optional.empty();
private Optional<Duration> timeout = Optional.empty();
public static final int DefaultMaxInboundMessageSize = 10 * 1024 * 1024;
private Builder(@NonNull NettyChannelBuilder channelBuilder) {
this.builder = channelBuilder;
this.builder.usePlaintext();
@ -66,6 +68,11 @@ public final class DamlLedgerClient implements LedgerClient {
return this;
}
public Builder withMaxInboundMessageSize(int maxInboundMessageSize) {
this.builder.maxInboundMessageSize(maxInboundMessageSize);
return this;
}
public DamlLedgerClient build() {
return new DamlLedgerClient(this.builder, this.accessToken, this.timeout);
}
@ -83,7 +90,9 @@ public final class DamlLedgerClient implements LedgerClient {
* builder's capabilities
*/
public static Builder newBuilder(@NonNull String host, int port) {
return new Builder(NettyChannelBuilder.forAddress(host, port));
return new Builder(
NettyChannelBuilder.forAddress(host, port)
.maxInboundMessageSize(Builder.DefaultMaxInboundMessageSize));
}
/**