code: @Override
     public void initialize() throws Exception
     {
        if (rar != null)
        {
           for (XAResource xar : rar.getXAResources(new ActivationSpec[] {as}))
           {
              // Trigger a recovery pass
              xar.recover(XAResource.TMSTARTRSCAN);
              xar.recover(XAResource.TMENDRSCAN);
           }
        }
        else
        {
           // Create ManagedConnection
           mc = mcf.createManagedConnection(subjectFactory.createSubject(securityDomain), null);
           
           // Trigger a recovery pass
           mc.getXAResource().recover(XAResource.TMSTARTRSCAN);
           mc.getXAResource().recover(XAResource.TMENDRSCAN);
        }
     }
docs: {@inheritDoc}