@Override
  public List<QueryMetadata> getAllLiveQueries() {
    return ImmutableList.copyOf(allLiveQueries.values());
  }
@Test
  public void shouldNotIncludeStreamPullInLiveQueries() {
    // Given:
    final Set<QueryMetadata> queries = ImmutableSet.of(
        givenCreate(registry, "q1", "source1", Optional.of("sink"), CREATE_AS),
        givenCreate(registry, "q2", "source2", Optional.empty(), CREATE_SOURCE),
        givenCreateTransient(registry, "transient1")
    );
    givenStreamPull(registry, "streamPull1");

    // When:
    final Set<QueryMetadata> listed
        = ImmutableSet.<QueryMetadata>builder().addAll(registry.getAllLiveQueries()).build();

    // Then:
    assertThat(listed, equalTo(queries));
  }