import com.google.common.collect.Sets;
import com.google.common.util.concurrent.Futures;
import java.io.InputStream;
+import java.net.InetSocketAddress;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import org.mockito.Mockito;
import org.mockito.invocation.InvocationOnMock;
import org.mockito.stubbing.Answer;
+import org.opendaylight.controller.md.sal.dom.api.DOMNotification;
import org.opendaylight.controller.md.sal.dom.api.DOMRpcResult;
import org.opendaylight.controller.md.sal.dom.api.DOMRpcService;
import org.opendaylight.controller.md.sal.dom.spi.DefaultDOMRpcResult;
device.onNotification(notification);
device.onNotification(notification);
- verify(facade, times(0)).onNotification(any(ContainerNode.class));
+ verify(facade, times(0)).onNotification(any(DOMNotification.class));
final NetconfSessionPreferences sessionCaps = getSessionCaps(true,
Lists.newArrayList(TEST_CAPABILITY));
device.handleSalInitializationSuccess(NetconfToNotificationTest.getNotificationSchemaContext(getClass()), sessionCaps, deviceRpc);
- verify(facade, timeout(10000).times(2)).onNotification(any(ContainerNode.class));
+ verify(facade, timeout(10000).times(2)).onNotification(any(DOMNotification.class));
device.onNotification(notification);
- verify(facade, timeout(10000).times(3)).onNotification(any(ContainerNode.class));
+ verify(facade, timeout(10000).times(3)).onNotification(any(DOMNotification.class));
}
@Test
final RemoteDeviceHandler<NetconfSessionPreferences> remoteDeviceHandler = mockCloseableClass(RemoteDeviceHandler.class);
doNothing().when(remoteDeviceHandler).onDeviceConnected(any(SchemaContext.class), any(NetconfSessionPreferences.class), any(NetconfDeviceRpc.class));
doNothing().when(remoteDeviceHandler).onDeviceDisconnected();
- doNothing().when(remoteDeviceHandler).onNotification(any(ContainerNode.class));
+ doNothing().when(remoteDeviceHandler).onNotification(any(DOMNotification.class));
return remoteDeviceHandler;
}
}
public RemoteDeviceId getId() {
- return new RemoteDeviceId("test-D");
+ return new RemoteDeviceId("test-D", InetSocketAddress.createUnresolved("localhost", 22));
}
public ExecutorService getExecutor() {