package jnpf.limsService.listener;
|
|
import jnpf.limsService.LimsMessageService;
|
import jnpf.limsService.event.LimsMessageDispatchEvent;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.event.TransactionPhase;
|
import org.springframework.transaction.event.TransactionalEventListener;
|
|
@Slf4j
|
@Component
|
@RequiredArgsConstructor
|
public class LimsMessageDispatchListener {
|
private final LimsMessageService messageService;
|
|
@Value("${lims.message.enabled:false}")
|
private boolean enabled;
|
|
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT, fallbackExecution = true)
|
public void handle(LimsMessageDispatchEvent event) {
|
if (!enabled) {
|
log.info("[lims-message-dispatch] skipped because lims.message.enabled=false, event={}, bizId={}",
|
event.getRequest().getEvent().getCode(), event.getRequest().getBizId());
|
return;
|
}
|
try {
|
messageService.send(event.getRequest());
|
} catch (Exception e) {
|
log.error("[lims-message-dispatch] event dispatch failed event={}, bizId={}",
|
event.getRequest().getEvent().getCode(), event.getRequest().getBizId(), e);
|
}
|
}
|
}
|
