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
9 package org.opendaylight.netconf.topology.singleton.impl.actors;
11 import akka.actor.ActorSystem;
12 import akka.testkit.TestActorRef;
13 import akka.testkit.javadsl.TestKit;
14 import java.util.concurrent.TimeUnit;
15 import org.junit.AfterClass;
16 import org.junit.Before;
17 import org.junit.Test;
18 import org.mockito.Mock;
19 import org.mockito.MockitoAnnotations;
20 import org.opendaylight.controller.md.sal.dom.api.DOMDataReadWriteTransaction;
21 import scala.concurrent.duration.Duration;
23 public class ReadWriteTransactionActorTest {
24 private static ActorSystem system = ActorSystem.apply();
27 private DOMDataReadWriteTransaction mockReadWriteTx;
29 private final ReadTransactionActorTestAdapter readTestAdapter = new ReadTransactionActorTestAdapter() {};
30 private final WriteTransactionActorTestAdapter writeTestAdapter = new WriteTransactionActorTestAdapter() {};
34 MockitoAnnotations.initMocks(this);
35 TestActorRef<?> actorRef = TestActorRef.create(system, ReadWriteTransactionActor.props(mockReadWriteTx,
36 Duration.apply(2, TimeUnit.SECONDS)));
37 readTestAdapter.init(mockReadWriteTx, system, actorRef);
38 writeTestAdapter.init(mockReadWriteTx, system, actorRef);
42 public static void staticTearDown() {
43 TestKit.shutdownActorSystem(system, true);
47 public void testRead() {
48 readTestAdapter.testRead();
52 public void testReadEmpty() {
53 readTestAdapter.testReadEmpty();
57 public void testReadFailure() {
58 readTestAdapter.testReadFailure();
62 public void testExists() {
63 readTestAdapter.testExists();
67 public void testExistsFailure() {
68 readTestAdapter.testExistsFailure();
72 public void testPut() {
73 writeTestAdapter.testPut();
77 public void testMerge() {
78 writeTestAdapter.testMerge();
82 public void testDelete() {
83 writeTestAdapter.testDelete();
87 public void testCancel() throws Exception {
88 writeTestAdapter.testCancel();
92 public void testSubmit() throws Exception {
93 writeTestAdapter.testSubmit();
97 public void testSubmitFail() throws Exception {
98 writeTestAdapter.testSubmitFail();
102 public void testIdleTimeout() throws Exception {
103 writeTestAdapter.testIdleTimeout();