@Override
    public void removeSink(McastRoute route, ConnectPoint connectPoint) {

        checkNotNull(route, "Route cannot be null");
        checkNotNull(connectPoint, "Sink cannot be null");

        store.storeSink(route, connectPoint, McastStore.Type.REMOVE);
    }
@Test
    public void testRemoveSink() {

        manager.addSource(r1, cp1);
        manager.addSink(r1, cp1);
        manager.addSink(r1, cp2);
        manager.removeSink(r1, cp2);

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