Semmal/eeg_portal
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

fix(mako): use @EventListener instead of @TransactionalEventListener

Browse Source 
The MakoConsensListener was not being triggered because the event was
published from a ScheduledExecutorService thread without transaction
context. Changed to @EventListener @Transactional to fix this.
This commit is contained in:
Bernhard Müller 2026-07-21 11:42:52 +02:00
parent 9d3fba05d6
commit 05ec18d550
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
eeg_backend/src/main/java/at/mueller/eeg/backend/community/event/listener/MakoConsensListener.java
View File

@ -10,9 +10,9 @@ import at.mueller.eeg.backend.community.repository.MeteringPointRepository;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationEventPublisher; import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.transaction.event.TransactionPhase; import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.event.TransactionalEventListener;
@Component @Component
@RequiredArgsConstructor @RequiredArgsConstructor
@ -22,7 +22,8 @@ public class MakoConsensListener {
private final MeteringPointRepository meteringPointRepository; private final MeteringPointRepository meteringPointRepository;
private final ApplicationEventPublisher eventPublisher; private final ApplicationEventPublisher eventPublisher;
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT) @EventListener
@Transactional
public void handleMakoConsensApproved(MakoConsensApprovedEvent event) { public void handleMakoConsensApproved(MakoConsensApprovedEvent event) {
log.info("MaKo-Consent erteilt für AT-Nummer: {}", event.atNumber()); log.info("MaKo-Consent erteilt für AT-Nummer: {}", event.atNumber());
@ -46,7 +47,8 @@ public class MakoConsensListener {
}, () -> log.error("Zählpunkt mit AT-Nummer {} nicht gefunden.", event.atNumber())); }, () -> log.error("Zählpunkt mit AT-Nummer {} nicht gefunden.", event.atNumber()));
} }
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT) @EventListener
@Transactional
public void handleMakoConsensRejected(MakoConsensRejectedEvent event) { public void handleMakoConsensRejected(MakoConsensRejectedEvent event) {
log.info("MaKo-Consent abgelehnt für AT-Nummer: {}. Grund: {}", event.atNumber(), event.reason()); log.info("MaKo-Consent abgelehnt für AT-Nummer: {}. Grund: {}", event.atNumber(), event.reason());
@ -63,7 +65,8 @@ public class MakoConsensListener {
}, () -> log.error("Zählpunkt mit AT-Nummer {} nicht gefunden.", event.atNumber())); }, () -> log.error("Zählpunkt mit AT-Nummer {} nicht gefunden.", event.atNumber()));
} }
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT) @EventListener
@Transactional
public void handleMakoConsensTechnicalFailed(MakoConsensTechnicalFailedEvent event) { public void handleMakoConsensTechnicalFailed(MakoConsensTechnicalFailedEvent event) {
log.warn("MaKo-Consent technischer Fehler für AT-Nummer: {}. Grund: {}", event.atNumber(), event.reason()); log.warn("MaKo-Consent technischer Fehler für AT-Nummer: {}. Grund: {}", event.atNumber(), event.reason());