org.wildfly.clustering.ee.infinispan

Class InfinispanBatcher

java.lang.Object

org.wildfly.clustering.ee.infinispan.InfinispanBatcher

All Implemented Interfaces:

Batcher<TransactionBatch>

public class InfinispanBatcher
extends Object
implements Batcher<TransactionBatch>

A Batcher implementation based on Infinispan's BatchContainer, except that its transaction reference is stored within the returned Batch object instead of a ThreadLocal. This also allows the user to call Batch#close() from a different thread than the one that created the Batch. In this case, however, the user must first resume the batch via resumeBatch(TransactionBatch).

Author:

Paul Ferraro

Constructor Summary

Constructors

Constructor and Description
InfinispanBatcher(org.infinispan.Cache<?,?> cache)
InfinispanBatcher(TransactionManager tm)

Method Summary

Modifier and Type	Method and Description
TransactionBatch	createBatch() Creates a batch.
BatchContext	resumeBatch(TransactionBatch batch) Resumes a batch.
TransactionBatch	suspendBatch() Suspends a batch.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InfinispanBatcher

public InfinispanBatcher(org.infinispan.Cache<?,?> cache)

InfinispanBatcher

public InfinispanBatcher(TransactionManager tm)

Method Detail

createBatch

public TransactionBatch createBatch()

Description copied from interface: Batcher

Creates a batch.

Specified by:

createBatch in interface Batcher<TransactionBatch>

Returns:

a batch.

resumeBatch

public BatchContext resumeBatch(TransactionBatch batch)

Description copied from interface: Batcher

Resumes a batch. Used if the specified batch was (or may have been) created by another thread.

Specified by:

resumeBatch in interface Batcher<TransactionBatch>

Parameters:

batch - an existing batch

Returns:

the context of the resumed batch

suspendBatch

public TransactionBatch suspendBatch()

Description copied from interface: Batcher

Suspends a batch.

Specified by:

suspendBatch in interface Batcher<TransactionBatch>

Returns:

the previously active batch, or null if there was no active batch