diff options
| -rw-r--r-- | aai-core/src/main/java/org/onap/aai/restcore/RESTAPI.java | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/aai-core/src/main/java/org/onap/aai/restcore/RESTAPI.java b/aai-core/src/main/java/org/onap/aai/restcore/RESTAPI.java index 3895f626..f26ac197 100644 --- a/aai-core/src/main/java/org/onap/aai/restcore/RESTAPI.java +++ b/aai-core/src/main/java/org/onap/aai/restcore/RESTAPI.java @@ -249,17 +249,18 @@ public class RESTAPI { throw new AAIException("AAI_3000", "uri and payload keys don't match"); } } - - protected DBConnectionType determineConnectionType(String fromAppId, String realTime) { - DBConnectionType type = DBConnectionType.REALTIME; + + protected DBConnectionType determineConnectionType(String fromAppId, String realTime) throws AAIException { + if (fromAppId == null) { + throw new AAIException("AAI_4009", "X-FromAppId is not set"); + } + boolean isRealTimeClient = AAIConfig.get("aai.realtime.clients", "").contains(fromAppId); if (isRealTimeClient || realTime != null) { - type = DBConnectionType.REALTIME; + return DBConnectionType.REALTIME; } else { - type = DBConnectionType.CACHED; + return DBConnectionType.CACHED; } - - return type; } /** |