<modelVersion>4.0.0</modelVersion>
<groupId>org.onap.dmaap.messagerouter.msgrtr</groupId>
<artifactId>msgrtr</artifactId>
- <version>1.1.15-SNAPSHOT</version>
+ <version>1.1.16-SNAPSHOT</version>
<packaging>jar</packaging>
<name>dmaap-messagerouter-msgrtr</name>
<description>Message Router - Restful interface built for kafka</description>
"metrics.send.cambria.topic");
if (null == metricTopicname)
metricTopicname = "msgrtr.apinode.metrics.dmaap";
+
+ boolean topicNameEnforced = false;
+ String topicNameStd = null;
+ topicNameStd = com.att.ajsc.beans.PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop,
+ "enforced.topic.name.AAF");
+ if (null != topicNameStd && topic.startsWith(topicNameStd)) {
+ topicNameEnforced = true;
+ }
if (null == ctx.getRequest().getHeader("Authorization") && !topic.equalsIgnoreCase(metricTopicname)) {
if (null != metatopic.getOwner() && !("".equals(metatopic.getOwner()))) {
}
}
// if headers are not provided then user will be null
- if (user == null && null != ctx.getRequest().getHeader("Authorization")) {
+ if (topicNameEnforced&&user == null && null != ctx.getRequest().getHeader("Authorization")) {
// the topic name will be sent by the client
DMaaPAAFAuthenticator aaf = new DMaaPAAFAuthenticatorImpl();