<modelVersion>4.0.0</modelVersion>
<groupId>org.onap.dmaap.messagerouter.msgrtr</groupId>
<artifactId>msgrtr</artifactId>
- <version>1.1.18-SNAPSHOT</version>
+ <version>1.1.19-SNAPSHOT</version>
<packaging>jar</packaging>
<name>dmaap-messagerouter-msgrtr</name>
<description>Message Router - Restful interface built for kafka</description>
validateIpBlacklist(errRespProvider, ctx);
final Topic metaTopic = ctx.getConfigReader().getfMetaBroker().getTopic(topic);
- if (metaTopic == null) {
- throw new CambriaApiException(errRespProvider.getTopicNotFoundError());
- }
+
final boolean isAAFTopic = authorizeClientWhenNeeded(ctx, metaTopic, topic, errRespProvider, PUBLISH_ACTION);
}
- @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()
major=1
minor=1
-patch=18
+patch=19
base_version=${major}.${minor}.${patch}