X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=transfer%2Fsrc%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2FTransferServiceApplication.java;h=80f1d4e13363c14f678181dac16025a66e17f4ec;hb=5bffe60126c5fa74bff59c91dfbd722d291b1c93;hp=49e57a349759d168bfeff880af3ad1b797f2c5a2;hpb=aa415473c0fced1fc60b876f4afa1909c34c5926;p=demos%2Fkafka%2Fdemos-kafka-payment-system-setup diff --git a/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferServiceApplication.java b/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferServiceApplication.java index 49e57a3..80f1d4e 100644 --- a/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferServiceApplication.java +++ b/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferServiceApplication.java @@ -2,7 +2,7 @@ package de.juplo.kafka.payment.transfer; import com.fasterxml.jackson.databind.ObjectMapper; -import de.juplo.kafka.payment.transfer.impl.TransferServiceImpl; +import de.juplo.kafka.payment.transfer.domain.TransferService; import lombok.extern.slf4j.Slf4j; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.ProducerConfig; @@ -34,12 +34,12 @@ public class TransferServiceApplication } @Bean - TransferServiceImpl transferService( + TransferService transferService( KafkaProducer producer, ObjectMapper mapper, TransferServiceProperties properties) { - return new TransferServiceImpl(producer, mapper, properties.topic); + return new TransferService(producer, mapper, properties.topic); }