Merge pull request #1084 from NSSuresh11/OLE-9227

OLE-9227 : Multiple bib imports are failing intermittently
openlibraryenvironment · Jul 12, 2017 · 5b009cf · 5b009cf
2 parents 7f0ba08 + 4904569
commit 5b009cf
Showing 1 changed file with 14 additions and 9 deletions.
diff --git a/...store-webapp/src/main/java/org/kuali/ole/dsng/rest/processor/OleDsNgOverlayProcessor.java b/...store-webapp/src/main/java/org/kuali/ole/dsng/rest/processor/OleDsNgOverlayProcessor.java
@@ -3,6 +3,7 @@
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.collections.map.HashedMap;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.log4j.Logger;
 import org.apache.solr.common.SolrInputDocument;
 import org.codehaus.jackson.JsonParseException;
 import org.codehaus.jackson.map.JsonMappingException;
@@ -37,6 +38,7 @@
  * Created by SheikS on 12/8/2015.
  */
 public class OleDsNgOverlayProcessor extends OleDsNgOverlayProcessorHelper implements DocstoreConstants {
+    private static final Logger LOG = Logger.getLogger(OleDsNgOverlayProcessor.class);
 
     @Autowired
     OleDsNGMemorizeService oleDsNGMemorizeService;
@@ -98,16 +100,19 @@ public String processBibAndHoldingsAndItems(String jsonBody) {
 
                         List<ItemRecordAndDataMapping> createItemRecordAndDataMappings = (List<ItemRecordAndDataMapping>) exchange.get(OleNGConstants.ITEMS_FOR_CREATE);
                         List<ItemRecordAndDataMapping> updateItemRecordAndDataMappings = (List<ItemRecordAndDataMapping>) exchange.get(OleNGConstants.ITEMS_FOR_UPDATE);
-                        synchronized (this) {
-                            processBib(solrInputDocumentMap, exchange, bibJSONDataObject, ops, bibRecord);
+                        LOG.info("processBib started");
+                        processBib(solrInputDocumentMap, exchange, bibJSONDataObject, ops, bibRecord);
+                        LOG.info("processBib completed");
+                        LOG.info("processHoldings started");
+                        processHoldings(solrInputDocumentMap, exchange, bibJSONDataObject, ops, holdingsForUpdateOrCreate);
+                        LOG.info("processHoldings completed");
+                        LOG.info("processEHoldings started");
+                        processEHoldings(solrInputDocumentMap, exchange, bibJSONDataObject, ops);
+                        LOG.info("processEHoldings completed");
+                        LOG.info("processItems started");
+                        processItems(solrInputDocumentMap, exchange, bibJSONDataObject, ops);
+                        LOG.info("processItems completed");
 
-                            processHoldings(solrInputDocumentMap, exchange, bibJSONDataObject, ops, holdingsForUpdateOrCreate);
-
-                            processEHoldings(solrInputDocumentMap, exchange, bibJSONDataObject, ops);
-
-                            processItems(solrInputDocumentMap, exchange, bibJSONDataObject, ops);
-
-                        }
                         bibRecord = (BibRecord) exchange.get(OleNGConstants.BIB);
                         buildBibResponses(bibResponse, bibRecord, exchange, operationsList);