Skip to content

Commit 9967d67

Browse files
committed
Fix styles
1 parent 4ad93eb commit 9967d67

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration/KafkaMultiBinderCustomConfigurationTests3148.java

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -78,26 +78,28 @@ private ConfigurableApplicationContext getBinderContext(String binderName) {
7878
Map<String, Map.Entry<Binder<?, ?, ?>, ConfigurableApplicationContext>> binderInstanceCache =
7979
(Map<String, Map.Entry<Binder<?, ?, ?>, ConfigurableApplicationContext>>) binderInstanceCacheField.get(this.binderFactory);
8080
return binderInstanceCache.get(binderName).getValue();
81-
} catch (Exception e) {
81+
}
82+
catch (Exception e) {
8283
fail();
8384
}
8485
return null;
8586
}
8687
@Configuration
8788
@EnableAutoConfiguration
88-
@PropertySource(value= "classpath:test3148.yml", factory = KafkaMultiBinderCustomConfigurationTests3148.YamlPropertySourceFactory.class)
89+
@PropertySource(value = "classpath:test3148.yml", factory = KafkaMultiBinderCustomConfigurationTests3148.YamlPropertySourceFactory.class)
8990
public static class SampleApplication {
9091

9192
@Bean
9293
public Consumer<String> testConsumer() {
93-
return consumer -> {};
94+
return consumer -> {
95+
96+
};
9497
}
9598

9699
@Bean
97100
public KafkaBindingRebalanceListener rebalanceListener() {
98101
return new KafkaBindingRebalanceListener() {
99-
public void onPartitionsAssigned(String bindingName, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer,
100-
Collection<TopicPartition> partitions, boolean initial) {
102+
public void onPartitionsAssigned(String bindingName, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Collection<TopicPartition> partitions, boolean initial) {
101103
// do nothing
102104
}
103105
};

0 commit comments

Comments
 (0)