对guava eventBus订户使用Spring事务性

Question

我正在尝试使用guava eventBus在Spring调度事件。在事件处理程序中，我需要hibernate获取一些数据——惰性获取——但是它抛出了错误

.hibernate.event.internal.DefaultLoadEventListener: HHH000327: Error performing load command : org.hibernate.SessionException: Session is closed!

事件总线抛出异常

GRAVE: Could not dispatch event

我的代码如下：

@Transactional
@AllowConcurrentEvents
@Subscribe
public void sessionEventReceived(Session session) {
    session.getTeacher();
}

对于实体会话，我有:

@ManyToOne(fetch = LAZY)
@JoinColumn(name = "TEACHER_ID")
protected Teacher teacher;

那么，我可以在事件总线订户中使用@Transactional吗？

编辑

我有一个服务，该服务将事件与对象会话（实体会话）一起发布，因此，在订阅者检索属性教师之前，Hibernate会话可能已关闭，我该如何处理？

Answer 1

要使@Transactional正常工作，应通过spring代理调用标记为@Transactional的方法。Spring将执行启动/提交/回滚工作。因此，如果您添加带有@Subscribe注释，则可能无法正常工作。（不确定，我应该测试或深入挖掘。

但是，您可以在订阅服务器中注入服务对象，并在处理程序函数中调用该服务的事务性函数。