import org.mockito.Mock;
import org.mockito.Mockito;
import org.mockito.runners.MockitoJUnitRunner;
+import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService;
import org.opendaylight.controller.sal.binding.api.BindingAwareBroker;
import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
import org.opendaylight.openflowplugin.api.OFConstants;
import org.opendaylight.openflowplugin.api.openflow.device.DeviceState;
import org.opendaylight.openflowplugin.api.openflow.device.handlers.DeviceInitializationPhaseHandler;
import org.opendaylight.openflowplugin.api.openflow.device.handlers.DeviceTerminationPhaseHandler;
-import org.opendaylight.openflowplugin.api.openflow.lifecycle.LifecycleConductor;
import org.opendaylight.openflowplugin.api.openflow.lifecycle.LifecycleService;
import org.opendaylight.openflowplugin.api.openflow.registry.ItemLifeCycleRegistry;
import org.opendaylight.openflowplugin.api.openflow.rpc.RpcContext;
@Mock
private MessageSpy mockMsgSpy;
@Mock
- private LifecycleConductor conductor;
- @Mock
private ConnectionContext connectionContext;
@Mock
private ItemLifeCycleRegistry itemLifeCycleRegistry;
private ExtensionConverterProvider extensionConverterProvider;
@Mock
private ConvertorExecutor convertorExecutor;
+ @Mock
+ private NotificationPublishService notificationPublishService;
@Rule
public ExpectedException expectedException = ExpectedException.none();
@Before
public void setUp() {
final NodeKey nodeKey = new NodeKey(nodeId);
- rpcManager = new RpcManagerImpl(rpcProviderRegistry, QUOTA_VALUE, conductor, extensionConverterProvider, convertorExecutor);
+ rpcManager = new RpcManagerImpl(rpcProviderRegistry, QUOTA_VALUE, extensionConverterProvider, convertorExecutor, notificationPublishService);
rpcManager.setDeviceInitializationPhaseHandler(deviceINitializationPhaseHandler);
GetFeaturesOutput featuresOutput = new GetFeaturesOutputBuilder()
Mockito.when(deviceContext.getMessageSpy()).thenReturn(messageSpy);
Mockito.when(deviceInfo.getNodeId()).thenReturn(nodeKey.getId());
Mockito.when(rpcProviderRegistry.addRoutedRpcImplementation(
- Matchers.<Class<RpcService>>any(), Matchers.any(RpcService.class)))
+ Matchers.any(), Matchers.any(RpcService.class)))
.thenReturn(routedRpcRegistration);
- Mockito.when(conductor.getDeviceContext(deviceInfo)).thenReturn(deviceContext);
Mockito.when(contexts.remove(deviceInfo)).thenReturn(removedContexts);
- }
-
- @Test
- public void onDeviceContextLevelUp() throws Exception {
- rpcManager.onDeviceContextLevelUp(deviceInfo, lifecycleService);
- verify(conductor).getDeviceContext(deviceInfo);
+ Mockito.when(lifecycleService.getDeviceContext()).thenReturn(deviceContext);
}
@Test
*/
@Test
public void onDeviceContextLevelDown1() {
- rpcManager.addRecordToContexts(deviceInfo,removedContexts);
+ rpcManager.addRecordToContexts(deviceInfo, removedContexts);
rpcManager.onDeviceContextLevelDown(deviceInfo);
verify(removedContexts,times(1)).close();
verify(deviceTerminationPhaseHandler,times(1)).onDeviceContextLevelDown(deviceInfo);