- public void testConcurrentCreate() throws InterruptedException, ExecutionException {
-
- DataModificationTransaction fooTx = baDataService.beginTransaction();
- DataModificationTransaction barTx = baDataService.beginTransaction();
-
- fooTx.putOperationalData(FOO_PATH, new TopLevelListBuilder().setKey(FOO_KEY).build());
- barTx.putOperationalData(BAR_PATH, new TopLevelListBuilder().setKey(BAR_KEY).build());
-
- Future<RpcResult<TransactionStatus>> fooFuture = fooTx.commit();
- Future<RpcResult<TransactionStatus>> barFuture = barTx.commit();
-
- RpcResult<TransactionStatus> fooResult = fooFuture.get();
- RpcResult<TransactionStatus> barResult = barFuture.get();
+ public void testConcurrentCreate() throws InterruptedException, ExecutionException, TimeoutException {