package jnpf.dmsService.search;
|
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.event.TransactionPhase;
|
import org.springframework.transaction.event.TransactionalEventListener;
|
|
@Component
|
@RequiredArgsConstructor
|
public class DmsSearchIndexJobCreatedListener {
|
private final DmsSearchIndexQueue queue;
|
|
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT, fallbackExecution = true)
|
public void handle(DmsSearchIndexJobCreatedEvent event) {
|
queue.push(event.getTask());
|
}
|
}
|
