File tree Expand file tree Collapse file tree 1 file changed +9
-1
lines changed
src/main/java/com/rabbitmq/stream/perf Expand file tree Collapse file tree 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) {
433433 converter = Utils .CreditsTypeConverter .class )
434434 private CreditSettings credits ;
435435
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+
436443 private MetricsCollector metricsCollector ;
437444 private PerformanceMetrics performanceMetrics ;
438445 private List <Monitoring > monitorings ;
@@ -666,7 +673,8 @@ public Integer call() throws Exception {
666673 .maxProducersByConnection (this .producersByConnection )
667674 .maxTrackingConsumersByConnection (this .trackingConsumersByConnection )
668675 .maxConsumersByConnection (this .consumersByConnection )
669- .rpcTimeout (Duration .ofSeconds (this .rpcTimeout ));
676+ .rpcTimeout (Duration .ofSeconds (this .rpcTimeout ))
677+ .requestedMaxFrameSize ((int ) this .requestedMaxFrameSize .toBytes ());
670678
671679 ChannelCustomizer channelCustomizer = channel -> {};
672680
You can’t perform that action at this time.
0 commit comments