Обернул дамп ОСО для перехвата исключений.

warehouse-common/warehouse-services/src/main/java/com/cdek/warehouse/services/gateway/impl/DumpOsoProcessorImpl.java

@@ -48,11 +48,18 @@ public class DumpOsoProcessorImpl implements DumpOsoProcessor {
 	public void processDumpOsoQueue() {
 		StatisticEk4 statistic = new StatisticEk4();
 		do {
-			LOG.info(String.format("Start to process Dump OSO chunk: offset=%d, size=%d", queueOffset, DUMP_OSO_CHUNK_SIZE));
-			statistic = synchronizeChunk(DUMP_OSO_CHUNK_SIZE, queueOffset, statistic);
-
-			queueOffset += statistic.chunkOsoEventCount;
-			LOG.info(String.format("Dump OSO chunk is processed: events count=%d", statistic.chunkOsoEventCount));
+			try {
+				LOG.info(String.format("Start to process Dump OSO chunk: offset=%d, size=%d", queueOffset, DUMP_OSO_CHUNK_SIZE));
+				statistic = synchronizeChunk(DUMP_OSO_CHUNK_SIZE, queueOffset, statistic);
+
+				queueOffset += statistic.chunkOsoEventCount;
+				LOG.info(String.format("Dump OSO chunk is processed: events count=%d", statistic.chunkOsoEventCount));
+			} catch (Exception ex) {
+				LOG.error(String.format("Dump OSO processing failed on chunk: offset=%d, size=%d", queueOffset, DUMP_OSO_CHUNK_SIZE), ex);
+			} catch (Throwable ex) {
+				LOG.error("Dump OSO processing catch throwable", ex);
+				throw ex;
+			}
 		} while (statistic.chunkOsoEventCount != 0);
 
 		logStatistic(statistic);

warehouse-common/warehouse-services/src/main/java/com/cdek/warehouse/services/gateway/load/DumpOsoEntityType.java

@@ -34,7 +34,6 @@ public enum DumpOsoEntityType {
 				return concrete;
 			}
 		}
-		//throw new IllegalArgumentException(String.format("Incorrect event type (%d) for warehouse event queue", type));
 		return null;
 	}
 }