public TxRequired(TransactionContainer container) 
{
        super(Type.Required, container);
}

 public  void afterInvoke(Object instance,
    TransactionContext context) throws SystemException, ApplicationException 
{
        try {
            if (context.clientTx != null) return;
            if (context.currentTx.getStatus() == Status.STATUS_ACTIVE) {
                commitTransaction(context, context.currentTx);
            } else {
                rollbackTransaction(context, context.currentTx);
            }
        } catch (javax.transaction.SystemException se) {
            logger.debug("Exception during getTransaction()", se);
            throw new SystemException(se);
        }
}

 public  void beforeInvoke(Object instance,
    TransactionContext context) throws SystemException, ApplicationException 
{
        context.callContext.set(Type.class, getPolicyType());
        try {
            context.clientTx = context.getTransactionManager().getTransaction();
            if (context.clientTx == null) {
                beginTransaction(context);
            }
            context.currentTx = context.getTransactionManager().getTransaction();
        } catch (javax.transaction.SystemException se) {
            logger.error("Exception during getTransaction()", se);
            throw new SystemException(se);
        }
}

 public  void handleApplicationException(Throwable appException,
    boolean rollback,
    TransactionContext context) throws SystemException, ApplicationException 
{
        if (rollback && context.currentTx != null) markTxRollbackOnly(context.currentTx);
        throw new ApplicationException(appException);
}

 public  void handleSystemException(Throwable sysException,
    Object instance,
    TransactionContext context) throws SystemException, ApplicationException 
{
        /* [1] Log the system exception or error **********/
        logSystemException(sysException, context);
        boolean runningInContainerTransaction = (!context.currentTx.equals(context.clientTx));
        if (runningInContainerTransaction) {
            /* [2] Mark the transaction for rollback. afterInvoke() will roll it back */
            markTxRollbackOnly(context.currentTx);
            /* [3] Discard instance. **************************/
            discardBeanInstance(instance, context.callContext);
            /* [4] Throw RemoteException to client ************/
            throwExceptionToServer(sysException);
        } else {
            /* [2] Mark the transaction for rollback. *********/
            markTxRollbackOnly(context.clientTx);
            /* [3] Discard instance. **************************/
            discardBeanInstance(instance, context.callContext);
            /* [4] Throw TransactionRolledbackException to client ************/
            throwTxExceptionToServer(sysException);
        }
}