File tree 1 file changed +9
-1
lines changed
src/main/java/com/rabbitmq/stream/perf
1 file changed +9
-1
lines changed Original file line number Diff line number Diff line change @@ -433,6 +433,13 @@ public void setMaxSegmentSize(ByteCapacity in) {
433
433
converter = Utils .CreditsTypeConverter .class )
434
434
private CreditSettings credits ;
435
435
436
+ @ CommandLine .Option (
437
+ names = {"--requested-max-frame-size" , "-rmfs" },
438
+ description = "maximum frame size to request" ,
439
+ defaultValue = "1048576" ,
440
+ converter = Utils .ByteCapacityTypeConverter .class )
441
+ private ByteCapacity requestedMaxFrameSize ;
442
+
436
443
private MetricsCollector metricsCollector ;
437
444
private PerformanceMetrics performanceMetrics ;
438
445
private List <Monitoring > monitorings ;
@@ -666,7 +673,8 @@ public Integer call() throws Exception {
666
673
.maxProducersByConnection (this .producersByConnection )
667
674
.maxTrackingConsumersByConnection (this .trackingConsumersByConnection )
668
675
.maxConsumersByConnection (this .consumersByConnection )
669
- .rpcTimeout (Duration .ofSeconds (this .rpcTimeout ));
676
+ .rpcTimeout (Duration .ofSeconds (this .rpcTimeout ))
677
+ .requestedMaxFrameSize ((int ) this .requestedMaxFrameSize .toBytes ());
670
678
671
679
ChannelCustomizer channelCustomizer = channel -> {};
672
680
You can’t perform that action at this time.
0 commit comments