X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdmf%2Fmr%2Fservice%2Fimpl%2FEventsServiceImplTest.java;fp=src%2Ftest%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdmf%2Fmr%2Fservice%2Fimpl%2FEventsServiceImplTest.java;h=f9178e1e27e4c85dcca601af035d587a036e8e92;hb=d12b53a7c46a151fda402f0c25120b26eef77ea5;hp=4abbe8970e9480be705415e93fea66ebc7b4e888;hpb=0cb3bb0b0c99a70dd31995a7dc4d06b53f6e43d0;p=dmaap%2Fmessagerouter%2Fmsgrtr.git diff --git a/src/test/java/org/onap/dmaap/dmf/mr/service/impl/EventsServiceImplTest.java b/src/test/java/org/onap/dmaap/dmf/mr/service/impl/EventsServiceImplTest.java index 4abbe89..f9178e1 100644 --- a/src/test/java/org/onap/dmaap/dmf/mr/service/impl/EventsServiceImplTest.java +++ b/src/test/java/org/onap/dmaap/dmf/mr/service/impl/EventsServiceImplTest.java @@ -402,16 +402,7 @@ public class EventsServiceImplTest { } - @Test - public void pushEvents_shouldFail_whenRequestedTopicDoesNotExist() throws Exception { - when(configurationReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker); - when(dmaapKafkaMetaBroker.getTopic("testTopic")).thenReturn(null); - - thrown.expect(CambriaApiException.class); - thrown.expectMessage(containsString(String.valueOf(HttpStatus.SC_NOT_FOUND))); - - eventsService.pushEvents(dMaapContext, "testTopic", iStream, "5", "13:00:00"); - } + @Test public void pushEvents_shouldFailDmaapAuthorization_whenTopicOwnerIsSet_andUserHasNoWritePermissionToTopic()