131132133134135136137138139140141
modifyResource(txn, pUrl, pid, "p1", "v2"); pVal = getResourceProperty(txn, pUrl, pid, "p1"); Assert.assertEquals(pVal, "v2"); txn.commitTx(); pVal = getResourceProperty(txn, pUrl, pid, "p1"); Assert.assertEquals(pVal, "v2"); }
180181182183184185186187188189190
terminator += "/_dead"; // an attempt to commit on this URI should fail: txn.httpRequest(new int[] { HttpURLConnection.HTTP_NOT_FOUND }, terminator, "PUT", TxMediaType.TX_STATUS_MEDIA_TYPE, TxStatusMediaType.TX_COMMITTED); // commit it properly txn.commitTx(); } @Test public void testTimeoutCleanup() throws InterruptedException { TxSupport txn = new TxSupport();