Skip to content

Commit fca2ffa

Browse files
committed
Adds missing method to SslBundles impls
1 parent 10963a6 commit fca2ffa

File tree

2 files changed

+12
-0
lines changed

2 files changed

+12
-0
lines changed

spring-cloud-starter-single-step-batch-job/src/test/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemReaderAutoConfigurationTests.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import java.util.HashMap;
2222
import java.util.List;
2323
import java.util.Map;
24+
import java.util.function.BiConsumer;
2425
import java.util.function.Consumer;
2526

2627
import org.apache.kafka.clients.admin.NewTopic;
@@ -245,6 +246,11 @@ public void addBundleUpdateHandler(String name, Consumer<SslBundle> updateHandle
245246

246247
}
247248

249+
@Override
250+
public void addBundleRegisterHandler(BiConsumer<String, SslBundle> registerHandler) {
251+
252+
}
253+
248254
@Override
249255
public List<String> getBundleNames() {
250256
return List.of();

spring-cloud-starter-single-step-batch-job/src/test/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemWriterTests.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import java.util.HashMap;
2121
import java.util.List;
2222
import java.util.Map;
23+
import java.util.function.BiConsumer;
2324

2425
import org.apache.kafka.clients.consumer.Consumer;
2526
import org.apache.kafka.clients.consumer.ConsumerRecords;
@@ -160,6 +161,11 @@ public void addBundleUpdateHandler(String name, java.util.function.Consumer<SslB
160161

161162
}
162163

164+
@Override
165+
public void addBundleRegisterHandler(BiConsumer<String, SslBundle> registerHandler) {
166+
167+
}
168+
163169
@Override
164170
public List<String> getBundleNames() {
165171
return List.of();

0 commit comments

Comments
 (0)