本文整理了Java中org.jboss.jbossts.xts.recovery.participant.at.XTSATRecoveryManager类的一些代码示例，展示了XTSATRecoveryManager类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。XTSATRecoveryManager类的具体详情如下：
包路径：org.jboss.jbossts.xts.recovery.participant.at.XTSATRecoveryManager
类名称：XTSATRecoveryManager

XTSATRecoveryManager介绍

[英]Abstract class defining API for managing both paritcipant and coordinator recovery On hteparticipant this is responsible for saving WS-AT participant recovery records during prepare, deleting them at commit and recreating and reactivating them during recovery. On the coordinator side it currently merely records whether coordinator recovery has copleted its first scan
[中]抽象类定义API，用于管理hteparticipant上的对等参与者和协调者恢复。该API负责在准备期间保存WS-AT参与者恢复记录，在提交时删除记录，并在恢复期间重新创建和重新激活这些记录。在协调器端，它目前只记录协调器恢复是否完成了第一次扫描

代码示例

代码示例来源：origin: org.jboss.jbossts.xts/recovery

/**
 * called by the service startup code before the recovery module is added to the recovery managers
 * module list
 */
public void install()
{
  // the manager is needed by both the participant or the coordinator recovery modules so whichever
  // one gets there first creates it. No synchronization is needed as modules are only ever
  // installed in a single thread
  XTSATRecoveryManager atRecoveryManager = XTSATRecoveryManager.getRecoveryManager();
  if (atRecoveryManager == null) {
    atRecoveryManager = new XTSATRecoveryManagerImple(_recoveryStore);
    XTSATRecoveryManager.setRecoveryManager(atRecoveryManager);
  }
  // Subordinate Coordinators register durable participants with their parent transaction so
  // we need to add an XTSATRecoveryModule which knows about the registered participants
  subordinateRecoveryModule = new XTSATSubordinateRecoveryModule();
  
  atRecoveryManager.registerRecoveryModule(subordinateRecoveryModule);
}

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

/**
   * Tests if there may be unknown coordinator entries in the recovery log.
   *
   * @return false if there may be unknown coordinator entries in the recovery log.
   */

  private static boolean areRecoveryLogEntriesAccountedFor()
  {
    return XTSATRecoveryManager.getRecoveryManager().isCoordinatorRecoveryStarted();
  }
}

代码示例来源：origin: org.jboss.jbossts.xts/recovery

/**
 * called by the service shutdown code after the recovery module is removed from the recovery managers
 * module list
 */
public void uninstall()
{
  XTSATRecoveryManager.getRecoveryManager().unregisterRecoveryModule(subordinateRecoveryModule);
}

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

XTSATRecoveryManager recoveryManager = XTSATRecoveryManager.getRecoveryManager();
else if (!recoveryManager.isParticipantRecoveryStarted()) {
  WSTLogger.i18NLogger.warn_wst11_messaging_ParticipantProcessorImpl_rollback_4(instanceIdentifier.toString());
else if (recoveryManager.findParticipantRecoveryRecord(instanceIdentifier.getInstanceIdentifier()) != null) {
  WSTLogger.i18NLogger.warn_wst11_messaging_ParticipantProcessorImpl_rollback_5(instanceIdentifier.toString());

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

} else {
  XTSATRecoveryManager recoveryManager = XTSATRecoveryManager.getRecoveryManager();
  boolean isRecoveryScanStarted = recoveryManager.isSubordinateCoordinatorRecoveryStarted();

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

if (!XTSATRecoveryManager.getRecoveryManager().deleteParticipantRecoveryRecord(id)) {

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

XTSATRecoveryManager recoveryManager = XTSATRecoveryManager.getRecoveryManager();
if (!recoveryManager.isParticipantPresent(recoverUid)) {
          participantRecord.restoreState(inputState);
          XTSATRecoveryManager.getRecoveryManager().addParticipantRecoveryRecord(recoverUid, participantRecord);
        } catch (ClassNotFoundException cnfe) {

代码示例来源：origin: org.jboss.jbossts/jbossxts

if (!XTSATRecoveryManager.getRecoveryManager().writeParticipantRecoveryRecord(recoveryRecord)) {
if (!XTSATRecoveryManager.getRecoveryManager().deleteParticipantRecoveryRecord(id)) {
if (!XTSATRecoveryManager.getRecoveryManager().deleteParticipantRecoveryRecord(id)) {

代码示例来源：origin: org.jboss.jbossts/jbossxts

/**
 * called by the service startup code before the recovery module is added to the recovery managers
 * module list
 */
public void install()
{
  // the manager is needed by both the participant or the coordinator recovery modules so whichever
  // one gets there first creates it. No synchronization is needed as modules are only ever
  // installed in a single thread
  XTSATRecoveryManager atRecoveryManager = XTSATRecoveryManager.getRecoveryManager();
  if (atRecoveryManager == null) {
    atRecoveryManager = new XTSATRecoveryManagerImple(_recoveryStore);
    XTSATRecoveryManager.setRecoveryManager(atRecoveryManager);
  }
  
  Implementations.install();
}

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

private void processTransactionsStatus()
{
  // Process the Vector of transaction Uids
  Enumeration transactionUidEnum = _transactionUidVector.elements() ;
  while ( transactionUidEnum.hasMoreElements() )
  {
    Uid currentUid = (Uid) transactionUidEnum.nextElement();
    try
    {
      if ( _recoveryStore.currentState( currentUid, _transactionType ) != StateStatus.OS_UNKNOWN )
      {
        doRecoverTransaction( currentUid ) ;
      }
    }
    catch ( ObjectStoreException ex )
    {
      RecoveryLogger.i18NLogger.warn_coordinator_at_SubordinateATCoordinatorRecoveryModule_3(currentUid, ex);
    }
  }
  XTSATRecoveryManager.getRecoveryManager().setSubordinateCoordinatorRecoveryStarted();
}

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

private void processTransactionsStatus()
{
  // Process the Vector of transaction Uids
  Enumeration transactionUidEnum = _transactionUidVector.elements() ;
  while ( transactionUidEnum.hasMoreElements() )
  {
    Uid currentUid = (Uid) transactionUidEnum.nextElement();
    try
    {
      if ( _recoveryStore.currentState( currentUid, _transactionType ) != StateStatus.OS_UNKNOWN )
      {
        doRecoverTransaction( currentUid ) ;
      }
    }
    catch ( ObjectStoreException ex )
    {
      RecoveryLogger.i18NLogger.warn_coordinator_at_ATCoordinatorRecoveryModule_3(currentUid, ex);
    }
  }
  XTSATRecoveryManager.getRecoveryManager().setCoordinatorRecoveryStarted();
}

代码示例来源：origin: org.jboss.jbossts/jbossxts

private void processParticipantsStatus()
{
  if (_participantUidVector != null) {
  // Process the Vector of transaction Uids
  Enumeration participantUidEnum = _participantUidVector.elements() ;
  while ( participantUidEnum.hasMoreElements() )
  {
    Uid currentUid = (Uid) participantUidEnum.nextElement();
    try
    {
      if ( _recoveryStore.currentState( currentUid, _participantType) != StateStatus.OS_UNKNOWN )
      {
        doRecoverParticipant( currentUid ) ;
      }
    }
    catch ( ObjectStoreException ex )
    {
      RecoveryLogger.i18NLogger.warn_participant_at_ATParticipantRecoveryModule_3(currentUid, ex);
    }
  }
  }
  // now get the AT recovery manager to try to activate recovered participants
  XTSATRecoveryManager.getRecoveryManager().recoverParticipants();
}

代码示例来源：origin: org.jboss.jbossts/jbosstxbridge

/**
 * MC lifecycle callback, used to unregister components from the recovery manager.
 */
public void stop()
{
  txbridgeLogger.i18NLogger.info_ibrm_stop();
  xtsATRecoveryManager.unregisterRecoveryModule(this);
  acRecoveryManager.removeModule(this, false);
  XARecoveryModule xaRecoveryModule = getXARecoveryModule();
  xaRecoveryModule.removeXAResourceOrphanFilter(this);
}

代码示例来源：origin: org.jboss.jbossts/jbosstxbridge

/**
 * MC lifecycle callback, used to register components with the recovery manager.
 */
public void start()
{
  txbridgeLogger.i18NLogger.info_ibrm_start();
  xtsATRecoveryManager.registerRecoveryModule(this);
  acRecoveryManager.addModule(this);
  XARecoveryModule xaRecoveryModule = getXARecoveryModule();
  xaRecoveryModule.addXAResourceOrphanFilter(this);
}

代码示例来源：origin: org.jboss.jbossts/jbossxts

XTSATRecoveryManager recoveryManager = XTSATRecoveryManager.getRecoveryManager();
else if (!recoveryManager.isParticipantRecoveryStarted()) {
  WSTLogger.i18NLogger.warn_wst11_messaging_ParticipantProcessorImpl_rollback_4(instanceIdentifier.toString());
else if (recoveryManager.findParticipantRecoveryRecord(instanceIdentifier.getInstanceIdentifier()) != null) {
  WSTLogger.i18NLogger.warn_wst11_messaging_ParticipantProcessorImpl_rollback_5(instanceIdentifier.toString());

代码示例来源：origin: org.jboss.jbossts/jbossxts

} else {
  XTSATRecoveryManager recoveryManager = XTSATRecoveryManager.getRecoveryManager();
  boolean isRecoveryScanStarted = recoveryManager.isSubordinateCoordinatorRecoveryStarted();

代码示例来源：origin: org.jboss.jbossts.xts/ws-t11

if (!XTSATRecoveryManager.getRecoveryManager().deleteParticipantRecoveryRecord(id)) {

代码示例来源：origin: org.jboss.jbossts/jbossxts

XTSATRecoveryManager recoveryManager = XTSATRecoveryManager.getRecoveryManager();
if (!recoveryManager.isParticipantPresent(recoverUid)) {
          participantRecord.restoreState(inputState);
          XTSATRecoveryManager.getRecoveryManager().addParticipantRecoveryRecord(recoverUid, participantRecord);
        } catch (ClassNotFoundException cnfe) {

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

if (!XTSATRecoveryManager.getRecoveryManager().writeParticipantRecoveryRecord(recoveryRecord)) {
if (!XTSATRecoveryManager.getRecoveryManager().deleteParticipantRecoveryRecord(id)) {
if (!XTSATRecoveryManager.getRecoveryManager().deleteParticipantRecoveryRecord(id)) {

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

/**
 * called by the service startup code before the recovery module is added to the recovery managers
 * module list
 */
public void install()
{
  // the manager is needed by both the participant or the coordinator recovery modules so whichever
  // one gets there first creates it. No synchronization is needed as modules are only ever
  // installed in a single thread
  XTSATRecoveryManager atRecoveryManager = XTSATRecoveryManager.getRecoveryManager();
  if (atRecoveryManager == null) {
    atRecoveryManager = new XTSATRecoveryManagerImple(_recoveryStore);
    XTSATRecoveryManager.setRecoveryManager(atRecoveryManager);
  }
  
  Implementations.install();
}