- final Set<DOMDataTreeShardWriteTransaction> txns = ImmutableSet.copyOf(idToTransaction.values());
- final ListenableFuture<List<Void>> listListenableFuture =
- Futures.allAsList(txns.stream().map(tx -> {
- tx.ready();
- return tx.submit();
- }).collect(Collectors.toList()));
+ producer.processTransaction(this);
+ return submitFuture;
+ }
+
+ CheckedFuture<Void, TransactionCommitFailedException> doSubmit(
+ final Consumer<ShardedDOMDataTreeWriteTransaction> success,
+ final BiConsumer<ShardedDOMDataTreeWriteTransaction, Throwable> failure) {
+
+ final ListenableFuture<List<Void>> listListenableFuture = Futures.allAsList(
+ idToTransaction.values().stream().map(tx -> {
+ LOG.debug("Readying tx {}", identifier);
+ tx.ready();
+ return tx.submit();
+ }).collect(Collectors.toList()));