@Override
public void begin(TxnType txnType) {
    if ( insideBegin.get() ) {
        super.begin(txnType);
        return;
    }

    insideBegin.set(true);
    try {
        // For the sync, we have to assume it will write.
        ReadWrite readWrite = ( txnType == TxnType.READ) ? ReadWrite.READ : ReadWrite.WRITE;
        txnSyncHandler.accept(readWrite);
        super.begin(txnType);
        if ( transactionMode() == ReadWrite.WRITE )
            monitor.txnBegin();
    } finally {
        insideBegin.set(false);
    }
    internalBegin();
}
 

@Override
public boolean promote() {
    // Do not use the wrapper which will redirect to the wrapped DSG
    // bypassing promote(Promote) below.
    // This is copied :-( from "Transactional"
    TxnType txnType = transactionType();
    if ( txnType == null )
        throw new JenaTransactionException("Not in a transaction") ;
    switch(txnType) {
        case WRITE :                  return true;
        case READ :                   return false;
        case READ_PROMOTE :           return promote(Promote.ISOLATED);
        case READ_COMMITTED_PROMOTE : return promote(Promote.READ_COMMITTED);
    }
    throw new JenaTransactionException("Can't determine promote '"+txnType+"'transaction");
}
 

@Override
public void begin(TxnType type) {}
 

@Override
public TxnType transactionType() {
    return null;
}
 

@Override
public void begin(TxnType type) {
    dataset.begin(type);
}
 

@Override
public TxnType transactionType() {
    return dataset.transactionType();
}
 

@Override
public void begin(TxnType type) {
    delegate.begin(type);
}
 

@Override
public TxnType transactionType() {
    return delegate.transactionType();
}
 

@Override
public void begin(TxnType type) {
	// TODO Auto-generated method stub
	
}
 

@Override
public TxnType transactionType() {
	// TODO Auto-generated method stub
	return null;
}
 

void onBegin(TxnType txnType);