- configTxChain = broker.createMergingTransactionChain(this);
- operTxChain = broker.createMergingTransactionChain(this);
+ configTxChain = broker.createMergingTransactionChain();
+ operTxChain = broker.createMergingTransactionChain();
+ configTxChain.addCallback(new FutureCallback<Empty>() {
+ @Override
+ public void onSuccess(Empty result) {
+ onTransactionChainSuccessful(configTxChain);
+ }
+
+ @Override
+ public void onFailure(Throwable cause) {
+ onTransactionChainFailed(configTxChain, cause);
+ }
+ });
+ operTxChain.addCallback(new FutureCallback<Empty>() {
+ @Override
+ public void onSuccess(Empty result) {
+ onTransactionChainSuccessful(operTxChain);
+ }
+
+ @Override
+ public void onFailure(Throwable cause) {
+ onTransactionChainFailed(operTxChain, cause);
+ }
+ });