@Override
    public void addSink(McastRoute route, ConnectPoint connectPoint) {
        checkNotNull(route, "Route cannot be null");
        checkNotNull(connectPoint, "Sink cannot be null");
        store.storeSink(route, connectPoint, McastStore.Type.ADD);

    }
@Test
    public void testAddSink() {
        manager.addSink(r1, cp1);

        validateEvents(McastEvent.Type.SINK_ADDED);
        assertEquals("Route is not equal", Sets.newHashSet(cp1), manager.fetchSinks(r1));
    }