Configure Infinispan/Quarkus for transactions

[schall1337]

Hi,
what is the right way to configure Quarkus + Infinispan (run as standalone not embedded) to use transactions?
It doesn't matter how I configure the Infinispan Cache, if I debug and run
myRemoteCache.getTransactionManager()
it always returns null.

Example how I configure the cache
{ "my-cache": { "distributed-cache": { "owners": "2", "mode": "SYNC", "remote-timeout": "17500", "statistics": true, "encoding": { "media-type": "application/x-protostream" }, "locking": { "concurrency-level": "1000", "isolation": "REPEATABLE_READ", "acquire-timeout": "15000", "striping": false }, "transaction": { "mode": "NON_XA", "locking": "OPTIMISTIC", "transaction-manager-lookup": "org.infinispan.transaction.lookup.GenericTransactionManagerLookup" }, "state-transfer": { "timeout": "60000" } } } }

and in Quarkus

my DAO class has @transactional and my RemoteCache @Inject and @Remote("my-cache") annotated. I do not have any problems with getting or putting values into the cache, just couldn't figure out the transaction thing.

Thanks

[quarkus-bot[bot]]

/cc @karesti (infinispan), @radcortez (config), @wburns (infinispan)

[karesti]

@schall1337 let me check this and I come back to you

[karesti]

@schall1337 I think we miss an integration point with the tx caches in the Quarkus integration, but this might be for historical reasons. In any case, the DAO or adding Transactional in Quarkus won't work to make use of Infinispan tx in remote cache.
I'm opening an issue to deal this case. This is how it works without Quarkus: https://github.com/infinispan/infinispan-simple-tutorials/blob/main/infinispan-remote/transactions/src/main/java/org/infinispan/tutorial/simple/remote/transaction/InfinispanRemoteTx.java#L60

[karesti]

@schall1337 I'll open an issue to document and add an extra for transactional caches.
Today, as a workaround, what you can do for your tx cache is accessing directly from the RemoteCacheManager

    @Inject
    RemoteCacheManager manager;

  

    // Add transaction config in the client too
    manager.getConfiguration()
             .addRemoteCache("mycache", c -> {
                c.transactionMode(TransactionMode.FULL_XA);
             });

     // Don't inject the cache, but grab it from the manager
     RemoteCache<String, Data> txMyCache = manager.getCache("txCache");
    
     // TransactionManager should not be null now
     TransactionManager transactionManager = txMyCache.getTransactionManager();
     transactionManager.begin();
    
    // Operations

    transactionManager.commit();

[karesti]

I created this issue and PR #50263

[schall1337]

thanks for the fast reply and implementation! Tried the workaround and works for the quarkus version I am using.

[karesti]

The pr has been merged in main, so it will land in next releases