Асинхронное сохранение данных в Quarkus

Я пытаюсь сохранить некоторые данные асинхронно с помощью Quarkus и Hibernate-Panache:

  Executors.newFixedThreadPool(1).execute(new Runnable() {
        @Override
        @Transactional // I need a transaction to persist the data
        public void run() {
            List<List<String>> myData = myCsvParser.parse(data);
            myRepository.importData(myData, myID);
            myBusinessService.doBusinessLogic(myID);
        }

К сожалению, я получаю:

Exception in thread "pool-5-thread-1" javax.enterprise.context.ContextNotActiveException: interface javax.enterprise.context.RequestScoped
    at io.quarkus.hibernate.orm.runtime.RequestScopedEntityManagerHolder_ClientProxy.arc$delegate(RequestScopedEntityManagerHolder_ClientProxy.zig:68)
    at io.quarkus.hibernate.orm.runtime.RequestScopedEntityManagerHolder_ClientProxy.getOrCreateEntityManager(RequestScopedEntityManagerHolder_ClientProxy.zig:220)
    at io.quarkus.hibernate.orm.runtime.entitymanager.TransactionScopedEntityManager.getEntityManager(TransactionScopedEntityManager.java:77)
    at io.quarkus.hibernate.orm.runtime.entitymanager.TransactionScopedEntityManager.contains(TransactionScopedEntityManager.java:285)

Проект репродуктора находится здесь: https://github.com/MarcusBiel/quarkus-reproducer

Заранее спасибо!


java asynchronous quarkus quarkus-panache
person Marcus Biel    schedule 15.09.2020    source источник

Ответы (1)


arrow_upward
2
arrow_downward

С помощью Мартина Коуба @martunek (и всех остальных) в чате Quarkus Zulip я заставил его работать так:

 @Dependent
public class MyTask implements Runnable {

    @Inject
    private MyParser myParser;

    @Inject
    private MyBusinessService myBusinessService;

    @Inject
    private MyRepository myRepository;

    private String csvData;
    private String myId;

    @Override
    @Transactional
    @ActivateRequestContext
    public void run() {
        List<List<String>> myData = csvParser.parse(csvData);
        myRepository.importData(myData, myId);
        myBusinessService.myBusinessMethod(myId);

    }

    public void setCsvData(String csvData) {
        this.csvData = csvData;
    }

    public void setMyId(String myId) {
        this.myId = myId;
    }
}

А в MyService мы выполняем эту задачу так:

ExecutorService executor = Executors.newFixedThreadPool(1);
MyTask myTask = Arc.container().instance(MyTask.class).get();
myTask.setCsvData(csvData);
myTask.setMyId(myId);
executor.execute(myTask);
person Marcus Biel    schedule 15.09.2020