File tree 1 file changed +13
-1
lines changed
src/main/java/com/rabbitmq/stream/perf
1 file changed +13
-1
lines changed Original file line number Diff line number Diff line change @@ -452,6 +452,12 @@ public class StreamPerfTest implements Callable<Integer> {
452
452
defaultValue = "false" )
453
453
private boolean forceReplicaForConsumers ;
454
454
455
+ @ CommandLine .Option (
456
+ names = {"--no-dev-mode" , "-ndm" },
457
+ description = "do not use development mode (useful for local cluster)" ,
458
+ defaultValue = "false" )
459
+ private boolean noDevMode ;
460
+
455
461
static class InstanceSyncOptions {
456
462
457
463
@ CommandLine .Option (
@@ -757,8 +763,14 @@ public Integer call() throws Exception {
757
763
shutdownService .wrap (
758
764
closeStep ("Closing environment executor" , () -> envExecutor .shutdownNow ()));
759
765
760
- boolean tls = isTls (this .uris );
761
766
AddressResolver addrResolver = null ;
767
+ if (this .noDevMode ) {
768
+ // we override the default address resolver with an instance that does the same thing
769
+ // the client library will not activate the development mode because of this
770
+ addrResolver = a -> a ;
771
+ }
772
+
773
+ boolean tls = isTls (this .uris );
762
774
if (loadBalancer ) {
763
775
int defaultPort = tls ? Client .DEFAULT_TLS_PORT : Client .DEFAULT_PORT ;
764
776
List <Address > addresses =
You can’t perform that action at this time.
0 commit comments