带有反应性panache单干涉仪的Pubsub消息未能创建带有会话的ReactiveTransaction是空错误。

Question

我有一个夸克项目连接到monogdb，使用反应性panache。

我希望将我的方法包装在事务中，我的当前代码大致如下所示：

@Traced
@ApplicationScoped
@Startup
public class MyReceiver implements com.google.cloud.pubsub.v1.MessageRecevier {
    @Override
    @ActivateRequestContext
    public void receiveMessage(PubsubMessage pubsubMessage, AckReplyConsumer ackReplyConsumer) {
        try {
            final String messageStr = pubsubMessage.getData().toStringUtf8();
            final MyMessage messageContent = objectMapper.readValue(messageStr, getTypeReference());
            handleMessage(messageContent).await().indefinitely();

            ackReplyConsumer.ack();
        } catch (Throwable ex) {
            log.warn("{} Message ID: [{}]  on [{}] ", ex.getMessage(), pubsubMessage.getMessageId(), subscriptionName);
            ackReplyConsumer.nack();
        }
    }

    public TypeReference<MyMessage> getTypeReference() { 
      return new TypeReference<>(){};
    }

    @ReactiveTransactional
    public Uni<Void> handleMessage(MyMessage message) {
        // code here is never reached
    }

}

但是，当我尝试测试我的代码并得到消息时，

我得到了一个错误：java.lang.NullPointerException: Cannot invoke "org.hibernate.reactive.mutiny.Mutiny$Session.withTransaction(java.util.function.Function)" because "session" is null

当代码试图进入handleMessage时，当触发@ReactiveTransactional方面时，就会发生这种情况。

我能注意到的是什么导致了这个原因，我找不到任何可以成为问题根源的东西。

Answer 1

目前，panache似乎不支持mongodb中的事务，而mongodb正是这个问题的根源。