@Test
public void testAddStreamingEngineWhenStreamingEngineAlreadyExistsViaMapServiceToClusterInNamespace() throws Exception {

    Long testNamespaceId = 1L;
    Namespace testNamespace = createTestNamespace(testNamespaceId, TEST_STREAMING_ENGINE, TEST_TIME_SERIES_DB);
    Collection<NamespaceServiceClusterMap> existingMappings = createTestMappingsForExisting(testNamespaceId);
    new Expectations() {{
        environmentService.getNamespace(testNamespaceId);
        result = testNamespace;
        environmentService.listServiceClusterMapping(testNamespaceId);
        result = existingMappings;
    }};
    NamespaceServiceClusterMap newMapping = new NamespaceServiceClusterMap(testNamespaceId, TEST_STREAMING_ENGINE, 2L);
    try {
        namespaceCatalogResource.mapServiceToClusterInNamespace(testNamespaceId, newMapping, securityContext);
        Assert.fail("Should throw BadRequestException");
    } catch (BadRequestException e) {
        // passed
    }
    new Verifications() {{
        environmentService.addOrUpdateServiceClusterMapping(withAny(new NamespaceServiceClusterMap()));
        times = 0;
    }};
}