2 * Copyright (c) 2015 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.controller.cluster;
10 import static java.util.Objects.requireNonNull;
12 import akka.japi.Procedure;
13 import akka.persistence.AbstractPersistentActor;
14 import akka.persistence.DeleteMessagesSuccess;
15 import akka.persistence.DeleteSnapshotsSuccess;
16 import akka.persistence.JournalProtocol;
17 import akka.persistence.SnapshotProtocol;
18 import akka.persistence.SnapshotSelectionCriteria;
21 * A DataPersistenceProvider implementation with persistence enabled.
23 public class PersistentDataProvider implements DataPersistenceProvider {
24 private final AbstractPersistentActor persistentActor;
26 public PersistentDataProvider(final AbstractPersistentActor persistentActor) {
27 this.persistentActor = requireNonNull(persistentActor, "persistentActor can't be null");
31 public boolean isRecoveryApplicable() {
36 public <T> void persist(final T entry, final Procedure<T> procedure) {
37 persistentActor.persist(entry, procedure);
41 public <T> void persistAsync(final T entry, final Procedure<T> procedure) {
42 persistentActor.persistAsync(entry, procedure);
46 public void saveSnapshot(final Object snapshot) {
47 persistentActor.saveSnapshot(snapshot);
51 public void deleteSnapshots(final SnapshotSelectionCriteria criteria) {
52 persistentActor.deleteSnapshots(criteria);
56 public void deleteMessages(final long sequenceNumber) {
57 persistentActor.deleteMessages(sequenceNumber);
61 public long getLastSequenceNumber() {
62 return persistentActor.lastSequenceNr();
66 public boolean handleJournalResponse(final JournalProtocol.Response response) {
67 return response instanceof DeleteMessagesSuccess;
71 public boolean handleSnapshotResponse(final SnapshotProtocol.Response response) {
72 return response instanceof DeleteSnapshotsSuccess;