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) {
private static AAFAuthn<?> aafAuthn;
private static AbsAAFLur<AAFPermission> aafLur;
- private static boolean props_ok = false;
-
private static final Logger logger = LoggerFactory.getLogger(Cadi3AAFProvider.class);
public Cadi3AAFProvider() {
logger.error("Unable to load " + CADI_PROPERTIES);
logger.error("Error", e);
}
-
- props_ok = true;
- if (props_ok == false) {
- return;
- }
}
if (aafAuthn == null) {
aafAuthn = null;
if (access != null)
access.log(e, "Failed to initialize AAF");
- props_ok = false;
}
}
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);