@Test public void testAddSource() { manager.addSource(r1, cp1); validateEvents(McastEvent.Type.SOURCE_ADDED); assertEquals("Route is not equal", cp1, manager.fetchSource(r1)); }
@Override public void addSource(McastRoute route, ConnectPoint connectPoint) { checkNotNull(route, "Route cannot be null"); checkNotNull(connectPoint, "Source cannot be null"); store.storeSource(route, connectPoint); }
MulticastRouteManager extends AbstractListenerManager<McastEvent, McastListener> implements MulticastRouteService { @Override public void addSource(McastRoute route, ConnectPoint connectPoint) { checkNotNull(route, "Route cannot be null"); checkNotNull(connectPoint, "Source cannot be null"); store.storeSource(route, connectPoint); } }
MulticastRouteManager extends AbstractListenerManager<McastEvent, McastListener> implements MulticastRouteService { @Override public void addSource(McastRoute route, ConnectPoint connectPoint) { checkNotNull(route, "Route cannot be null"); checkNotNull(connectPoint, "Source cannot be null"); store.storeSource(route, connectPoint); }  }
MulticastRouteManager extends AbstractListenerManager<McastEvent, McastListener> implements MulticastRouteService { @Override public void addSource(McastRoute route, ConnectPoint connectPoint) { checkNotNull(route, "Route cannot be null"); checkNotNull(connectPoint, "Source cannot be null"); store.storeSource(route, connectPoint); }  @Activate void activate(); @Deactivate void deactivate(); @Override void add(McastRoute route); @Override void remove(McastRoute route); @Override Set<McastRoute> getRoutes(); @Override void addSource(McastRoute route, ConnectPoint connectPoint); @Override void addSink(McastRoute route, ConnectPoint connectPoint); @Override void removeSink(McastRoute route, ConnectPoint connectPoint); @Override ConnectPoint fetchSource(McastRoute route); @Override Set<ConnectPoint> fetchSinks(McastRoute route); }
MulticastRouteManager extends AbstractListenerManager<McastEvent, McastListener> implements MulticastRouteService { @Override public void addSource(McastRoute route, ConnectPoint connectPoint) { checkNotNull(route, "Route cannot be null"); checkNotNull(connectPoint, "Source cannot be null"); store.storeSource(route, connectPoint); }  @Activate void activate(); @Deactivate void deactivate(); @Override void add(McastRoute route); @Override void remove(McastRoute route); @Override Set<McastRoute> getRoutes(); @Override void addSource(McastRoute route, ConnectPoint connectPoint); @Override void addSink(McastRoute route, ConnectPoint connectPoint); @Override void removeSink(McastRoute route, ConnectPoint connectPoint); @Override ConnectPoint fetchSource(McastRoute route); @Override Set<ConnectPoint> fetchSinks(McastRoute route);  }