diff options
author | Jon Bratseth <bratseth@yahoo-inc.com> | 2016-07-07 10:24:43 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@yahoo-inc.com> | 2016-07-07 10:24:43 +0200 |
commit | 8411578893a53d79c51d0d866666673755d16f3b (patch) | |
tree | dbc912ba0615ec17b421697e40f1524673afee6e /zkfacade | |
parent | e5c09f0cfd3077498b5243adba2f8fda35318aa7 (diff) |
Give up using a type parameter for transaction operations, again
Diffstat (limited to 'zkfacade')
-rw-r--r-- | zkfacade/src/main/java/com/yahoo/vespa/curator/transaction/CuratorTransaction.java | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/zkfacade/src/main/java/com/yahoo/vespa/curator/transaction/CuratorTransaction.java b/zkfacade/src/main/java/com/yahoo/vespa/curator/transaction/CuratorTransaction.java index c0d4843f435..1345cabcd40 100644 --- a/zkfacade/src/main/java/com/yahoo/vespa/curator/transaction/CuratorTransaction.java +++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/transaction/CuratorTransaction.java @@ -10,7 +10,7 @@ import org.apache.curator.framework.api.transaction.CuratorTransactionFinal; * * @author lulf */ -public class CuratorTransaction extends AbstractTransaction<CuratorOperation> { +public class CuratorTransaction extends AbstractTransaction { private final Curator curator; private boolean prepared = false; @@ -34,8 +34,8 @@ public class CuratorTransaction extends AbstractTransaction<CuratorOperation> { @Override public void prepare() { TransactionChanges changes = new TransactionChanges(); - for (CuratorOperation operation : operations()) - operation.check(curator, changes); + for (Operation operation : operations()) + ((CuratorOperation)operation).check(curator, changes); prepared = true; } @@ -46,8 +46,8 @@ public class CuratorTransaction extends AbstractTransaction<CuratorOperation> { if ( ! prepared) prepare(); org.apache.curator.framework.api.transaction.CuratorTransaction transaction = curator.framework().inTransaction(); - for (CuratorOperation operation : operations()) { - transaction = operation.and(transaction); + for (Operation operation : operations()) { + transaction = ((CuratorOperation)operation).and(transaction); } ((CuratorTransactionFinal) transaction).commit(); } catch (Exception e) { |