@Test public void testCleanup() throws ResourceException { MicroserviceXAResource xa = new MicroserviceXAResource("a", null); xa.getUnderlyingConnection().setCurrentTxId("a"); xa.getUnderlyingConnection().cleanup(); try{ xa.getUnderlyingConnection().wasExecuteSuccessful(); fail("no exception"); }catch(NullPointerException 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);  }