Bug 8153: Enforce check-style rules for netconf - mdsal-netconf-notification

[netconf.git] / netconf / mdsal-netconf-notification / src / test / java / org / opendaylight / controller / config / yang / netconf / mdsal / notification / NotificationToMdsalWriterTest.java

diff --git a/netconf/mdsal-netconf-notification/src/test/java/org/opendaylight/controller/config/yang/netconf/mdsal/notification/NotificationToMdsalWriterTest.java b/netconf/mdsal-netconf-notification/src/test/java/org/opendaylight/controller/config/yang/netconf/mdsal/notification/NotificationToMdsalWriterTest.java
index 6084d92cca0a62952a1b2b9bbc19e06668f015d4..072fc3657ab0b31cd9e9a03b3ac7ba78fa23e191 100644 (file)
--- a/netconf/mdsal-netconf-notification/src/test/java/org/opendaylight/controller/config/yang/netconf/mdsal/notification/NotificationToMdsalWriterTest.java
+++ b/netconf/mdsal-netconf-notification/src/test/java/org/opendaylight/controller/config/yang/netconf/mdsal/notification/NotificationToMdsalWriterTest.java
@@ -55,14 +55,14 @@ public class NotificationToMdsalWriterTest {
         doReturn(dataBroker).when(session).getSALService(DataBroker.class);
 
         WriteTransaction tx = mock(WriteTransaction.class);
-        doNothing().when(tx).merge(any(LogicalDatastoreType.class), any(InstanceIdentifier.class)
-                , any(DataObject.class), anyBoolean());
+        doNothing().when(tx).merge(any(LogicalDatastoreType.class), any(InstanceIdentifier.class),
+                any(DataObject.class), anyBoolean());
         doNothing().when(tx).delete(any(LogicalDatastoreType.class), any(InstanceIdentifier.class));
         doReturn(Futures.immediateCheckedFuture(null)).when(tx).submit();
         doReturn(tx).when(dataBroker).newWriteOnlyTransaction();
 
-        writer = new NotificationToMdsalWriter(notificationCollector);
-        writer.onSessionInitiated(session);
+        writer = new NotificationToMdsalWriter(notificationCollector, dataBroker);
+        writer.start();
     }
 
     @Test
@@ -74,7 +74,8 @@ public class NotificationToMdsalWriterTest {
 
         writer.onStreamRegistered(testStream);
 
-        verify(dataBroker.newWriteOnlyTransaction()).merge(LogicalDatastoreType.OPERATIONAL, streamIdentifier, testStream, true);
+        verify(dataBroker.newWriteOnlyTransaction()).merge(LogicalDatastoreType.OPERATIONAL, streamIdentifier,
+                testStream, true);
 
         writer.onStreamUnregistered(testStreamName);
 
@@ -82,7 +83,7 @@ public class NotificationToMdsalWriterTest {
     }
 
     @Test
-    public void testClose(){
+    public void testClose() {
         doNothing().when(notificationRegistration).close();
 
         final InstanceIdentifier streamIdentifier = InstanceIdentifier.create(Netconf.class);