| Methods Summary |
|---|
| public Request | _create_request(Context ctx, java.lang.String operation, NVList arg_list, NamedValue result)
throw no_implement;
|
| public Request | _create_request(Context ctx, java.lang.String operation, NVList arg_list, NamedValue result, ExceptionList exceptions, ContextList contexts)
throw no_implement;
|
| public org.omg.CORBA.Object | _duplicate()
throw no_implement;
|
| public org.omg.CORBA.DomainManager[] | _get_domain_managers()
throw no_implement;
|
| public org.omg.CORBA.Object | _get_interface_def()
throw no_implement;
|
| public org.omg.CORBA.Policy | _get_policy(int policy_type)
throw no_implement;
|
| public int | _hash(int maximum)
throw no_implement;
|
| public boolean | _is_a(java.lang.String repository_id)
throw no_implement;
|
| public boolean | _is_equivalent(org.omg.CORBA.Object that)
throw no_implement;
|
| public boolean | _non_existent()
throw no_implement;
|
| public void | _release()
throw no_implement;
|
| public Request | _request(java.lang.String operation)
throw no_implement;
|
| public org.omg.CORBA.Object | _set_policy_override(org.omg.CORBA.Policy[] policies, org.omg.CORBA.SetOverrideType set_add)
throw no_implement;
|
| public void | addSynchronization(javax.transaction.Synchronization sync, boolean interposed)
if (!interposed)
syncs.addElement(sync);
else
interposedSyncs.addElement(sync);
|
| public void | after_completion(Status status)
try {
int result = TransactionManagerImpl.mapStatus(status);
// Interposed Syncs First and then the regular syncs
Enumeration e1 = interposedSyncs.elements();
while (e1.hasMoreElements()) {
Synchronization sync = (Synchronization) e1.nextElement();
try {
sync.afterCompletion(result);
} catch (Exception ex) {
_logger.log(Level.WARNING,
"jts.unexpected_error_occurred_in_after_completion",ex);
}
}
Enumeration e = syncs.elements();
while (e.hasMoreElements()) {
Synchronization sync = (Synchronization) e.nextElement();
try {
sync.afterCompletion(result);
} catch (Exception ex) {
_logger.log(Level.WARNING,
"jts.unexpected_error_occurred_in_after_completion",ex);
}
}
} finally {
try {
// deactivate object
if (corbaRef != null) {
if (poa == null) {
poa = Configuration.getPOA("transient"/*#Frozen*/);
}
poa.deactivate_object(poa.reference_to_id(corbaRef));
}
} catch (Exception ex) {
_logger.log(Level.WARNING,
"jts.unexpected_error_occurred_in_after_completion",ex);
}
}
|
| public void | before_completion()
// Regular syncs first then the interposed syncs
Enumeration e = syncs.elements();
while (e.hasMoreElements()) {
Synchronization sync = (Synchronization) e.nextElement();
try {
sync.beforeCompletion();
} catch (RuntimeException rex) {
try {
state.setRollbackOnly();
} catch (Exception ex1) {
_logger.log(Level.WARNING,
"jts.unexpected_error_occurred_in_after_completion",ex1);
}
_logger.log(Level.WARNING,
"jts.unexpected_error_occurred_in_after_completion",rex);
} catch (Exception ex) {
_logger.log(Level.WARNING,
"jts.unexpected_error_occurred_in_after_completion",ex);
}
}
Enumeration e1 = interposedSyncs.elements();
while (e1.hasMoreElements()) {
Synchronization sync = (Synchronization) e1.nextElement();
try {
sync.beforeCompletion();
} catch (RuntimeException rex) {
try {
state.setRollbackOnly();
} catch (Exception ex1) {
_logger.log(Level.WARNING,
"jts.unexpected_error_occurred_in_after_completion",ex1);
}
_logger.log(Level.WARNING,
"jts.unexpected_error_occurred_in_after_completion",rex);
} catch (Exception ex) {
_logger.log(Level.WARNING,
"jts.unexpected_error_occurred_in_after_completion",ex);
}
}
state.beforeCompletion();
|
| public org.omg.CosTransactions.Synchronization | getCORBAReference()
if (poa == null) {
poa = Configuration.getPOA("transient"/*#Frozen*/);
}
if (corbaRef == null) {
try {
poa.activate_object(this);
corbaRef = SynchronizationHelper.narrow(
poa.servant_to_reference(this));
//corbaRef = (org.omg.CosTransactions.Synchronization) this;
} catch (Exception ex) {
_logger.log(Level.SEVERE,
"jts.unexpected_error_in_getcorbareference",ex);
}
}
return corbaRef;
|
