File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
main/java/com/rabbitmq/stream/perf
test/java/com/rabbitmq/stream/perf Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -612,9 +612,8 @@ public Integer call() throws Exception {
612612
613613 String producerName = this .producerNameStrategy .apply (stream , i + 1 );
614614 if (producerName != "" ) {
615- producerBuilder = producerBuilder
616- .name (producerName )
617- .confirmTimeout (Duration .ZERO );
615+ producerBuilder =
616+ producerBuilder .name (producerName ).confirmTimeout (Duration .ZERO );
618617 }
619618
620619 Producer producer =
Original file line number Diff line number Diff line change @@ -169,7 +169,8 @@ void producerConsumerNameStrategyConverterShouldReturnEmptyStringWhenPatternIsEm
169169 @ Test
170170 void producerConsumerNameStrategyConverterShouldReturnPatternStrategyWhenAsked () {
171171 NameStrategyConverter nameStrategyConverter = new NameStrategyConverter ();
172- BiFunction <String , Integer , String > nameStrategy = nameStrategyConverter .convert ("stream-%s-consumer-%d" );
172+ BiFunction <String , Integer , String > nameStrategy =
173+ nameStrategyConverter .convert ("stream-%s-consumer-%d" );
173174 assertThat (nameStrategy ).isInstanceOf (PatternNameStrategy .class );
174175 assertThat (nameStrategy .apply ("s1" , 2 )).isEqualTo ("stream-s1-consumer-2" );
175176 }
You can’t perform that action at this time.
0 commit comments