我正在使用 Spring-AMQP 来监视 Play 应用程序中的 RabbitMQ 消息队列。
问题是我无法从侦听器代码访问我的数据库,因为 JPA 上下文未在此范围内打开。
我了解 Play Framework 管理 JPA 上下文,以便在处理 HTTP 请求时打开它,但是有没有办法可以从 Play 控制器/作业外部使用 JPA?
我正在使用 Spring-AMQP 来监视 Play 应用程序中的 RabbitMQ 消息队列。
问题是我无法从侦听器代码访问我的数据库,因为 JPA 上下文未在此范围内打开。
我了解 Play Framework 管理 JPA 上下文,以便在处理 HTTP 请求时打开它,但是有没有办法可以从 Play 控制器/作业外部使用 JPA?
刚刚发现答案是使用 JPAPlugin!
示例监听器方法:
public void process(Message message) {
JPAPlugin.startTx(false);
boolean rollBack = false;
try {
// work with your models
JPA.em().flush();
} catch (RuntimeException e) {
rollBack = true;
// throw exception to prevent msg ACK, need to refine error handling :)
throw e;
} finally {
JPAPlugin.closeTx(rollBack);
}
}