@Test public void testHowRecoveryIsDone() { MicroserviceXAResource xa = new MicroserviceXAResource("a", null); assertTrue(xa.isHandleRecoveryInternally()); try{ xa.getUnderlyingConnection().getTransactionsInNeedOfRecovery(); fail("no exception"); }catch(UnsupportedOperationException e){ } }
@Override protected UnderlyingConnection getUnderlyingConnection() { return underlyingConnection; }
MicroserviceXAResource extends AbstractTransactionAssistanceXAResource { @Override protected UnderlyingConnection getUnderlyingConnection() { return underlyingConnection; } }
MicroserviceXAResource extends AbstractTransactionAssistanceXAResource { @Override protected UnderlyingConnection getUnderlyingConnection() { return underlyingConnection; } MicroserviceXAResource(String jndiName, final CommitRollbackCallback commitRollbackCallback); }
MicroserviceXAResource extends AbstractTransactionAssistanceXAResource { @Override protected UnderlyingConnection getUnderlyingConnection() { return underlyingConnection; } MicroserviceXAResource(String jndiName, final CommitRollbackCallback commitRollbackCallback); @Override boolean isSameRM(XAResource xares); static void configure(long minAgeOfTransactionInMSBeforeRelevantForRecovery, File recoveryStatePersistenceDirectory); }
MicroserviceXAResource extends AbstractTransactionAssistanceXAResource { @Override protected UnderlyingConnection getUnderlyingConnection() { return underlyingConnection; } MicroserviceXAResource(String jndiName, final CommitRollbackCallback commitRollbackCallback); @Override boolean isSameRM(XAResource xares); static void configure(long minAgeOfTransactionInMSBeforeRelevantForRecovery, File recoveryStatePersistenceDirectory);  }