Using @Transactional for Subscriptions data fetcher

Hello,

We were wondering whether it’s possible to define an execution strategy (or anything else) that would run the data fetchers for each new message in the subscription flux within a transaction, similar to the following code, which handles this for queries and mutations :

public class TransactionalAsyncExecutionStrategy extends AsyncExecutionStrategy {

    public TransactionalAsyncExecutionStrategy(
            final DataFetcherExceptionHandler handler
    ) {
        super(handler);
    }

    @Override
    @Transactional
    public CompletableFuture<ExecutionResult> execute(
            final ExecutionContext executionContext,
            final ExecutionStrategyParameters parameters
    ) throws NonNullableFieldWasNullException {
        return super.execute(executionContext, parameters);
    }
}

How can we cover this case ?

Thank you by advance

Another sources:

https://github.com/spring-projects/spring-graphql/issues/448#issuecomment-1825502735

Start by reading the issue's TransactionalAsyncExecutionStrategy example and the AsyncExecutionStrategy.execute entry point, including DataFetcherExceptionHandler, ExecutionContext, and ExecutionStrategyParameters. Review the referenced spring-graphql issue comment for prior context. Done would be a clear, supported answer or implementation for running subscription data fetchers for each message within a transaction.