@Override
  public int getCanaryDistributionPolicy()
  {
    switch (_clusterInfoItem.getClusterPropertiesItem().getDistribution())
    {
      case STABLE: return 0;
      case CANARY: return 1;
      default: return -1;
    }
  }
@Test(dataProvider = "getCanaryDistributionPoliciesTestData")
  public void testGetCanaryDistributionPolicy(CanaryDistributionProvider.Distribution distribution, int expectedValue)
  {
    ClusterInfoJmx clusterInfoJmx = new ClusterInfoJmx(
        new ClusterInfoItem(_mockedSimpleBalancerState, new ClusterProperties("Foo"), new PartitionAccessor() {
          @Override
          public int getMaxPartitionId() {
            return 0;
          }

          @Override
          public int getPartitionId(URI uri) {
            return 0;
          }
        }, distribution)
    );
    Assert.assertEquals(clusterInfoJmx.getCanaryDistributionPolicy(), expectedValue);
  }