com.j_spaces.sadapter.datasource
Class BulkDataPersisterContext

java.lang.Object
  com.j_spaces.sadapter.datasource.BulkDataPersisterContext

public class BulkDataPersisterContext
extends Object

BulkDataPersisterContext an operation context that is accessible on mirror in BulkDataPersister.executeBulk(List) method.
BulkDataPersisterContext should be used to consolidate distributed transactions on the mirror side.
BulkDataPersisterContext is not accessible on any other space except mirror and not in any other method except BulkDataPersister.executeBulk(List)

Example of mirror implementation:

 public void executeBulk(List bulk) throws DataSourceException {
            BulkDataPersisterContext context = BulkDataPersisterContext.getCurrentContext();

           if (context.isTransactional()) {
               TransactionParticipantData txData = context.getTransactionData();


                long id = txData.getTransactionId();
                int participantId = txData.getParticipantId();
                int participantsCount = txData.getParticipantsCount();

                // add to pending transactions      
                ....


                // if all transactions parts arrived - execute bulk
                ....

            }
            else
            {
               //regular execution
               ....
            }

        }
 

Since:

7.1

Author:

anna

Constructor Summary

BulkDataPersisterContext(net.jini.core.transaction.server.TransactionParticipantData transactionData)

Method Summary

static BulkDataPersisterContext	getCurrentContext() Get the context of the current thread
net.jini.core.transaction.server.TransactionParticipantData	getTransactionData()
boolean	isTransactional()
static void	resetContext() Resets the current context
static void	setContext(BulkDataPersisterContext context) Set context

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkDataPersisterContext

public BulkDataPersisterContext(net.jini.core.transaction.server.TransactionParticipantData transactionData)

Parameters:

transactionData -

Method Detail

getCurrentContext

public static BulkDataPersisterContext getCurrentContext()

Get the context of the current thread

Returns:

setContext

public static void setContext(BulkDataPersisterContext context)

Set context

resetContext

public static void resetContext()

Resets the current context

getTransactionData

public net.jini.core.transaction.server.TransactionParticipantData getTransactionData()

isTransactional

public boolean isTransactional()