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.SnapshotSelectionCriteria;
14 import org.opendaylight.controller.cluster.common.actor.ExecuteInSelfActor;
15 import org.slf4j.Logger;
16 import org.slf4j.LoggerFactory;
19 * A DataPersistenceProvider implementation with persistence disabled, essentially a no-op.
21 public class NonPersistentDataProvider implements DataPersistenceProvider {
22 private static final Logger LOG = LoggerFactory.getLogger(NonPersistentDataProvider.class);
24 private final ExecuteInSelfActor actor;
26 public NonPersistentDataProvider(final ExecuteInSelfActor actor) {
27 this.actor = requireNonNull(actor);
31 public boolean isRecoveryApplicable() {
36 public <T> void persist(final T entry, final Procedure<T> procedure) {
37 invokeProcedure(procedure, entry);
41 public <T> void persistAsync(final T entry, final Procedure<T> procedure) {
42 actor.executeInSelf(() -> invokeProcedure(procedure, entry));
46 public void saveSnapshot(final Object snapshot) {
51 public void deleteSnapshots(final SnapshotSelectionCriteria criteria) {
56 public void deleteMessages(final long sequenceNumber) {
61 public long getLastSequenceNumber() {
65 @SuppressWarnings("checkstyle:IllegalCatch")
66 static <T> void invokeProcedure(final Procedure<T> procedure, final T argument) {
68 procedure.apply(argument);
69 } catch (Exception e) {
70 LOG.error("An unexpected error occurred", e);