- public void testConcurrentCreate() throws InterruptedException, ExecutionException {
-
- DataModificationTransaction fooTx = baDataService.beginTransaction();
- DataModificationTransaction barTx = baDataService.beginTransaction();
-
- fooTx.putOperationalData(NODE_FOO_PATH, new NodeBuilder().setKey(NODE_FOO_KEY).build());
- barTx.putOperationalData(NODE_BAR_PATH, new NodeBuilder().setKey(NODE_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 {