feasible becausewe need to support transactions in an asynchronous batch. Reads a piece of input data and advance to the next one. Reads a piece of input data and advance to the next one. Implementationsmust return null at the end of the inputdata set. In a transactional setting, caller might get the same

is closed when the flow ends. If theflow ends by reaching a "commit" end-state, changes made to managed persistent entities during the course of flowexecution are flushed to the database in a transaction. The persistence context can be referenced from within this flow by the "entityManager" variable

Gemfire-specific subclass of TransactionException, indicating a transaction failure at commit time.

A template with convenience operations, exception translation and implicit transaction for modifying methods

Wrapper for an AbstractEndpoint that exposes a management interface.

callbacks that manage restart data. Provide a task executor to use when executing the tasklet. In the case of an asynchronous taskExecutor(TaskExecutor) the number of concurrent tasklet executionscan be throttled (beyond any throttling provided by a thread pool). Sets the transaction attributes for the

the next one. Implementationsmust return null at the end of the inputdata set. In a transactional setting, caller might get the same itemtwice from successive calls (or otherwise), if the first call was in atransaction that rolled back. Description copied from class: CheckpointSupport Used to close the

the next one. Implementationsmust return null at the end of the inputdata set. In a transactional setting, caller might get the same itemtwice from successive calls (or otherwise), if the first call was in atransaction that rolled back.

An implementation of PlatformTransactionManager that provides transaction-like semantics toMessageSources that are not inherently transactional. It does not make suchsources transactional; rather, together with a TransactionSynchronizationFactory, it providesthe ability to synchronize operations after

result in storeKey. Watch given key for modifications during transaction started with multi(). Watch given keys for modifications during transaction started with multi(). Flushes all the previously watch(Object) keys. Mark the start of a transaction block. Commands will be queued and can then be executed