diff --git a/mod-source-record-manager-server/src/main/java/org/folio/verticle/DataImportJournalBatchConsumerVerticle.java b/mod-source-record-manager-server/src/main/java/org/folio/verticle/DataImportJournalBatchConsumerVerticle.java index 047a48dcc..0f7cfffff 100644 --- a/mod-source-record-manager-server/src/main/java/org/folio/verticle/DataImportJournalBatchConsumerVerticle.java +++ b/mod-source-record-manager-server/src/main/java/org/folio/verticle/DataImportJournalBatchConsumerVerticle.java @@ -84,7 +84,6 @@ import static org.folio.rest.jaxrs.model.DataImportEventTypes.DI_SRS_MARC_HOLDINGS_RECORD_NOT_MATCHED; import static org.folio.rest.jaxrs.model.DataImportEventTypes.DI_SRS_MARC_HOLDINGS_RECORD_UPDATED; import static org.folio.rest.jaxrs.model.DataImportEventTypes.DI_SRS_MARC_HOLDING_RECORD_CREATED; -import static org.folio.rest.jaxrs.model.DataImportEventTypes.DI_MARC_FOR_UPDATE_RECEIVED; import static org.folio.services.RecordsPublishingServiceImpl.RECORD_ID_HEADER; import static org.folio.services.util.EventHandlingUtil.constructModuleName; import static org.springframework.beans.factory.config.BeanDefinition.SCOPE_PROTOTYPE; @@ -159,7 +158,6 @@ public List getEvents() { DI_SRS_MARC_AUTHORITY_RECORD_NOT_MATCHED.value(), DI_SRS_MARC_HOLDINGS_RECORD_NOT_MATCHED.value(), DI_SRS_MARC_HOLDINGS_RECORD_MATCHED.value(), - DI_MARC_FOR_UPDATE_RECEIVED.value(), DI_INVENTORY_INSTANCE_CREATED.value(), DI_INVENTORY_INSTANCE_UPDATED.value(), DI_INVENTORY_INSTANCE_NOT_MATCHED.value(), diff --git a/mod-source-record-manager-server/src/main/java/org/folio/verticle/consumers/StoredRecordChunksKafkaHandler.java b/mod-source-record-manager-server/src/main/java/org/folio/verticle/consumers/StoredRecordChunksKafkaHandler.java index 4b52ba686..680559b62 100644 --- a/mod-source-record-manager-server/src/main/java/org/folio/verticle/consumers/StoredRecordChunksKafkaHandler.java +++ b/mod-source-record-manager-server/src/main/java/org/folio/verticle/consumers/StoredRecordChunksKafkaHandler.java @@ -145,7 +145,6 @@ public Future handle(KafkaConsumerRecord record) { } private void saveCreatedRecordsInfoToDataImportLog(List storedRecords, String tenantId) { - LOGGER.debug("saveCreatedRecordsInfoToDataImportLog :: count: {}", storedRecords.size()); MappingRuleCacheKey cacheKey = new MappingRuleCacheKey(tenantId, storedRecords.get(0).getRecordType()); mappingRuleCache.get(cacheKey).onComplete(rulesAr -> { diff --git a/mod-source-record-manager-server/src/main/java/org/folio/verticle/consumers/util/JournalParams.java b/mod-source-record-manager-server/src/main/java/org/folio/verticle/consumers/util/JournalParams.java index 655779480..6cda4d2b5 100644 --- a/mod-source-record-manager-server/src/main/java/org/folio/verticle/consumers/util/JournalParams.java +++ b/mod-source-record-manager-server/src/main/java/org/folio/verticle/consumers/util/JournalParams.java @@ -3,7 +3,6 @@ import static org.folio.rest.jaxrs.model.EntityType.EDIFACT_INVOICE; import static org.folio.rest.jaxrs.model.JournalRecord.ActionStatus.ERROR; import static org.folio.rest.jaxrs.model.JournalRecord.ActionType.CREATE; -import static org.folio.rest.jaxrs.model.JournalRecord.ActionType.UPDATE; import java.util.Arrays; import java.util.Map; @@ -118,14 +117,6 @@ public Optional getJournalParams(DataImportEventPayload eventPayl JournalRecord.ActionStatus.COMPLETED)); } }, - DI_MARC_FOR_UPDATE_RECEIVED { - @Override - public Optional getJournalParams(DataImportEventPayload eventPayload) { - return Optional.of(new JournalParams(UPDATE, - JournalRecord.EntityType.MARC_BIBLIOGRAPHIC, - JournalRecord.ActionStatus.COMPLETED)); - } - }, DI_INVENTORY_INSTANCE_CREATED { @Override public Optional getJournalParams(DataImportEventPayload eventPayload) {