X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fcommon%2Factor%2FAbstractUntypedPersistentActor.java;h=326733f377e21d62fcf4865a0eeab10ad14e7ad6;hb=be1359a7418043c3961fd8ffa91eacd224bed952;hp=432c2d5615227d7d67f856bef6215fd550053084;hpb=d2d4cefa4d8d662554b7f2fc0b0dd568d0db1180;p=controller.git diff --git a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/common/actor/AbstractUntypedPersistentActor.java b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/common/actor/AbstractUntypedPersistentActor.java index 432c2d5615..326733f377 100644 --- a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/common/actor/AbstractUntypedPersistentActor.java +++ b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/common/actor/AbstractUntypedPersistentActor.java @@ -8,10 +8,7 @@ package org.opendaylight.controller.cluster.common.actor; -import akka.japi.Procedure; -import akka.persistence.SnapshotSelectionCriteria; import akka.persistence.UntypedPersistentActor; -import org.opendaylight.controller.cluster.DataPersistenceProvider; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -69,71 +66,4 @@ public abstract class AbstractUntypedPersistentActor extends UntypedPersistentAc } unhandled(message); } - - protected class PersistentDataProvider implements DataPersistenceProvider { - - public PersistentDataProvider(){ - - } - - @Override - public boolean isRecoveryApplicable() { - return true; - } - - @Override - public void persist(T o, Procedure procedure) { - AbstractUntypedPersistentActor.this.persist(o, procedure); - } - - @Override - public void saveSnapshot(Object o) { - AbstractUntypedPersistentActor.this.saveSnapshot(o); - } - - @Override - public void deleteSnapshots(SnapshotSelectionCriteria criteria) { - AbstractUntypedPersistentActor.this.deleteSnapshots(criteria); - } - - @Override - public void deleteMessages(long sequenceNumber) { - AbstractUntypedPersistentActor.this.deleteMessages(sequenceNumber); - } - } - - protected class NonPersistentDataProvider implements DataPersistenceProvider { - - public NonPersistentDataProvider(){ - - } - - @Override - public boolean isRecoveryApplicable() { - return false; - } - - @Override - public void persist(T o, Procedure procedure) { - try { - procedure.apply(o); - } catch (Exception e) { - LOG.error("An unexpected error occurred", e); - } - } - - @Override - public void saveSnapshot(Object o) { - } - - @Override - public void deleteSnapshots(SnapshotSelectionCriteria criteria) { - - } - - @Override - public void deleteMessages(long sequenceNumber) { - - } - } }