public void updateStatusCount(final String state, final int change) {
    updateStatusCount(KafkaStreams.State.valueOf(state), change);
  }
@Test
  public void shouldRoundTripWhenNotEmpty() {
    // Given:
    queryStatusCount.updateStatusCount(KafkaStreams.State.RUNNING, 2);
    queryStatusCount.updateStatusCount(KafkaStreams.State.ERROR, 10);
    queryStatusCount.updateStatusCount(KsqlQueryStatus.UNRESPONSIVE, 1);

    // When:
    final String json = assertDeserializedToSame(queryStatusCount);

    // Then:
    assertThat(json, is("{"
        + "\"RUNNING\":2,"
        + "\"ERROR\":10,"
        + "\"UNRESPONSIVE\":1"
        + "}"));
  }