2 * Copyright (c) 2017 Pantheon Technologies s.r.o. 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.netconf.topology.singleton.impl.actors;
10 import akka.actor.ActorSystem;
11 import akka.testkit.TestActorRef;
12 import akka.testkit.javadsl.TestKit;
13 import java.time.Duration;
14 import org.junit.AfterClass;
15 import org.junit.Before;
16 import org.junit.Test;
17 import org.junit.runner.RunWith;
18 import org.mockito.Mock;
19 import org.mockito.junit.MockitoJUnitRunner;
20 import org.opendaylight.mdsal.dom.api.DOMDataTreeReadWriteTransaction;
22 @RunWith(MockitoJUnitRunner.StrictStubs.class)
23 public class ReadWriteTransactionActorTest {
24 private static ActorSystem system = ActorSystem.apply();
27 private DOMDataTreeReadWriteTransaction mockReadWriteTx;
29 private final ReadTransactionActorTestAdapter readTestAdapter = new ReadTransactionActorTestAdapter() {};
30 private final WriteTransactionActorTestAdapter writeTestAdapter = new WriteTransactionActorTestAdapter() {};
34 TestActorRef<?> actorRef = TestActorRef.create(system, ReadWriteTransactionActor.props(mockReadWriteTx,
35 Duration.ofSeconds(2)));
36 readTestAdapter.init(mockReadWriteTx, system, actorRef);
37 writeTestAdapter.init(mockReadWriteTx, system, actorRef);
41 public static void staticTearDown() {
42 TestKit.shutdownActorSystem(system, true);
46 public void testRead() {
47 readTestAdapter.testRead();
51 public void testReadEmpty() {
52 readTestAdapter.testReadEmpty();
56 public void testReadFailure() {
57 readTestAdapter.testReadFailure();
61 public void testExists() {
62 readTestAdapter.testExists();
66 public void testExistsFailure() {
67 readTestAdapter.testExistsFailure();
71 public void testPut() {
72 writeTestAdapter.testPut();
76 public void testMerge() {
77 writeTestAdapter.testMerge();
81 public void testDelete() {
82 writeTestAdapter.testDelete();
86 public void testCancel() throws Exception {
87 writeTestAdapter.testCancel();
91 public void testSubmit() throws Exception {
92 writeTestAdapter.testSubmit();
96 public void testSubmitFail() throws Exception {
97 writeTestAdapter.testSubmitFail();
101 public void testIdleTimeout() throws Exception {
102 writeTestAdapter.testIdleTimeout();