Как сохранить Entity в отдельном потоке с JPA на сервере приложений J2EE?

Question

У меня есть приложение чата, которое должно хранить сообщения в БД. Но соединение с БД немного медленное, поэтому оно задерживает ответ клиенту чата.

Можно ли сохранить сущность сообщения в отдельном потоке? Что мне действительно нужно: уменьшить задержку перед отправкой-получением сообщения на клиенте.

Я пытаюсь это сделать, но это не работает.

Дао объект:

@Stateless
public class MessagesDAO {
    @PersistenceContext(type= PersistenceContextType.EXTENDED)
    private EntityManager entityManager;

    private PersistenceThread persistenceThread = new PersistenceThread();

    //another methods

    public void addMessage(Message message) {
        Thread thread = new Thread(persistenceThread);
        persistenceThread.setMessage(message);
        thread.start();
    }

    private class PersistenceThread implements Runnable {
        private Message message;

        public void setMessage(Message message) {
            this.message = message;
        }

        public void run() {
            entityManager.persist(message);
        }
    }
}

Служба интерфейса, которая вызывает DAO для сохранения нового сообщения, а затем возвращает его клиентам:

@Stateless
@Path("/messages")
@Produces("application/xml")
@Consumes("application/xml")
public class MessagesServiceImpl {
    @EJB
    private MessagesDAO messagesDAO;

    @POST
    @Broadcast(resumeOnBroadcast = true)
    public Message postMessage(Message message) {
        messagesDAO.addMessage(message);
        return message;
    }

    @GET
    @Path("/wait")
    @Suspend(outputComments = false)
    public Message waitForLastMessage() {
        return null;
    }
    //another methods

}

Спасибо.

Answer 1

Попробуйте аннотацию @ Asynchronous :

@Stateless
public class MessagesDAO {

    @PersistenceContext(type = PersistenceContextType.EXTENDED)
    private EntityManager entityManager;

    @Asynchronous
    public void addMessage(Message message) {
      entityManager.persist(message);
    }
}

Помните, что для этого требуется EJB 3.1.