summaryrefslogtreecommitdiffstats
path: root/zkfacade
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@yahoo-inc.com>2016-07-07 10:24:43 +0200
committerJon Bratseth <bratseth@yahoo-inc.com>2016-07-07 10:24:43 +0200
commit8411578893a53d79c51d0d866666673755d16f3b (patch)
treedbc912ba0615ec17b421697e40f1524673afee6e /zkfacade
parente5c09f0cfd3077498b5243adba2f8fda35318aa7 (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.java10
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) {