Skip to content

Commit

Permalink
Ajout cas ou nbRun = null
Browse files Browse the repository at this point in the history
  • Loading branch information
SamuelQuetin committed Oct 14, 2024
1 parent b4d2b9f commit e70e390
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions src/main/java/fr/abes/logskbart/kafka/LogsListener.java
Original file line number Diff line number Diff line change
Expand Up @@ -65,6 +65,9 @@ public void listenInfoKbart2KafkaAndErrorKbart2Kafka(ConsumerRecord<String, Stri
logKbart.setNbLine(Integer.parseInt(((key.length > 1) ? key[1] : "-1") ));

Integer nbRun = service.getLastNbRun(logKbart.getPackageName());
if(nbRun == null){
nbRun = 0;
}
if(logKbart.getMessage().contains("Debut envois kafka de :")){
nbRun++;
}
Expand Down

0 comments on commit e70e390

Please sign in to comment.