|
GigaSpaces XAP 7.1 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.j_spaces.sadapter.datasource.BulkDataPersisterContext
public class BulkDataPersisterContext
BulkDataPersisterContext
an operation context that is accessible on mirror in BulkDataPersister
.executeBulk(List
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
....
}
}
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 |
---|
public BulkDataPersisterContext(net.jini.core.transaction.server.TransactionParticipantData transactionData)
transactionData
- Method Detail |
---|
public static BulkDataPersisterContext getCurrentContext()
public static void setContext(BulkDataPersisterContext context)
public static void resetContext()
public net.jini.core.transaction.server.TransactionParticipantData getTransactionData()
public boolean isTransactional()
|
GigaSpaces XAP 7.1 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |