@Override
  protected void handleRemove(final String listenTo)
  {
    ClusterInfoItem clusterInfoRemoved = _simpleLoadBalancerState.getClusterInfo().remove(listenTo);
    _simpleLoadBalancerState.notifyListenersOnClusterInfoRemovals(clusterInfoRemoved);
    _simpleLoadBalancerState.notifyClusterListenersOnRemove(listenTo);
  }
@Test
  public void testHandleRemove()
  {
    String clusterName = "mock-cluster-foo";
    ClusterLoadBalancerSubscriberFixture fixture = new ClusterLoadBalancerSubscriberFixture();
    ClusterInfoItem clusterInfoItemToRemove =
        new ClusterInfoItem(fixture._simpleLoadBalancerState, new ClusterProperties(clusterName),
            new PartitionAccessor() {
              @Override
              public int getMaxPartitionId() {
                return 0;
              }

              @Override
              public int getPartitionId(URI uri) {
                return 0;
              }
            }, CanaryDistributionProvider.Distribution.CANARY);
    fixture._simpleLoadBalancerState.getClusterInfo().put(clusterName, clusterInfoItemToRemove);
    fixture.getMockSubscriber(false).handleRemove(clusterName);

    Assert.assertFalse(fixture._simpleLoadBalancerState.getClusterInfo().containsKey(clusterName));
    verify(fixture._simpleLoadBalancerState, times(1)).notifyListenersOnClusterInfoRemovals(
        clusterInfoItemToRemove
    );
    verify(fixture._simpleLoadBalancerState, times(1)).notifyClusterListenersOnRemove(
        clusterName
    );
  }