diff options
Diffstat (limited to 'aai-resources/src/main/java/org/onap/aai/rest/bulk/BulkSingleTransactionConsumer.java')
-rw-r--r-- | aai-resources/src/main/java/org/onap/aai/rest/bulk/BulkSingleTransactionConsumer.java | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/aai-resources/src/main/java/org/onap/aai/rest/bulk/BulkSingleTransactionConsumer.java b/aai-resources/src/main/java/org/onap/aai/rest/bulk/BulkSingleTransactionConsumer.java index 03cfa8f..674c1b4 100644 --- a/aai-resources/src/main/java/org/onap/aai/rest/bulk/BulkSingleTransactionConsumer.java +++ b/aai-resources/src/main/java/org/onap/aai/rest/bulk/BulkSingleTransactionConsumer.java @@ -74,7 +74,11 @@ public class BulkSingleTransactionConsumer extends RESTAPI { initLogging(req, transId, sourceOfTruth); try { - type = DBConnectionType.REALTIME; + if(AAIConfig.get("aai.use.realtime", "true").equals("true")){ + type = DBConnectionType.REALTIME; + } else { + type = this.determineConnectionType(sourceOfTruth, realTime); + } // unmarshall the payload. Gson gson = new Gson(); |