private static AAFCon<?> aafcon;
private static final String CADI_PROPERTIES = "/opt/kafka/config/cadi.properties";
private static final String AAF_LOCATOR_ENV = "aaf_locate_url";
- private static final String MR_NAMESPACE = " org.onap.dmaap.mr";
+ private static final String MR_NAMESPACE = "org.onap.dmaap.mr";
public static AAFAuthn<?> getAafAuthn() throws CadiException {
if (aafAuthn == null) {
hasPermission = true;
return hasPermission;
}
- AAFPermission perm = new AAFPermission(MR_NAMESPACE, permission, instance, action);
+ AAFPermission perm = new AAFPermission(null, permission, instance, action);
if (aafLur != null) {
hasPermission = aafLur.fish(new UnAuthPrincipal(userId), perm);
logger.trace("Permission: " + perm.getKey() + " for user :" + userId + " found: " + hasPermission);