X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Fdemos-kafka-payment-system-transfer;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2Fadapter%2FTransferConsumer.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2Fadapter%2FTransferConsumer.java;h=c66c534ac0d3b7a7a26c0866d86afebd9639cec0;hp=1cae540ff24f5a2d7d2dea4f10e182060cd871c5;hb=6d64dff7c410dd644e42a25b0a67513c3b30cfd3;hpb=9b5a2fb9d42baeb4ddde2ac146e2f8e61a1fc550

diff --git a/src/main/java/de/juplo/kafka/payment/transfer/adapter/TransferConsumer.java b/src/main/java/de/juplo/kafka/payment/transfer/adapter/TransferConsumer.java
index 1cae540..c66c534 100644
--- a/src/main/java/de/juplo/kafka/payment/transfer/adapter/TransferConsumer.java
+++ b/src/main/java/de/juplo/kafka/payment/transfer/adapter/TransferConsumer.java
@@ -172,7 +172,7 @@ public class TransferConsumer implements Runnable, ConsumerRebalanceListener
 
           TransferStateChangedEvent stateChangedEvent =
               mapper.readValue(record.value(), TransferStateChangedEvent.class);
-          useCases.handleStateChange(stateChangedEvent.getId(), stateChangedEvent.getState());
+          useCases.handleStateChange(stateChangedEvent);
           break;
       }
     }