Commit 06c2aa16 authored by Dmitriy Novikov's avatar Dmitriy Novikov
Browse files

Fixed Indexer service user email usage

parent 513ae974
......@@ -29,17 +29,17 @@ import lombok.RequiredArgsConstructor;
import org.apache.http.HttpStatus;
import org.elasticsearch.ElasticsearchStatusException;
import org.elasticsearch.client.RestHighLevelClient;
import org.opengroup.osdu.indexer.di.JaxRsDpsLog;
import org.opengroup.osdu.core.common.model.http.AppException;
import org.opengroup.osdu.core.common.model.http.DpsHeaders;
import org.opengroup.osdu.core.common.model.indexer.IndexingStatus;
import org.opengroup.osdu.indexer.di.JobStatus;
import org.opengroup.osdu.core.common.model.indexer.OperationType;
import org.opengroup.osdu.core.common.model.indexer.RecordInfo;
import org.opengroup.osdu.core.common.model.indexer.RecordStatus;
import org.opengroup.osdu.core.common.model.search.RecordChangedMessages;
import org.opengroup.osdu.core.common.search.ElasticIndexNameResolver;
import org.opengroup.osdu.indexer.logging.AuditLogger;
import org.opengroup.osdu.indexer.di.AuditLogger;
import org.opengroup.osdu.indexer.di.JaxRsDpsLog;
import org.opengroup.osdu.indexer.di.JobStatus;
import org.opengroup.osdu.indexer.provider.interfaces.IPublisher;
import org.opengroup.osdu.indexer.util.ElasticClientHandler;
import org.opengroup.osdu.indexer.util.IndexerQueueTaskBuilder;
......@@ -118,6 +118,7 @@ public class IndexerServiceImpl implements IndexerService {
private void putHeadersFromMessages(Map<String, String> attributes) {
headers.put("authorization", attributes.get("authorization"));
headers.put("data-partition-id", attributes.get("data-partition-id"));
headers.put("user", attributes.get("user"));
}
private void retryAndEnqueueFailedRecords(List<RecordInfo> recordInfos, List<String> failuresRecordIds, RecordChangedMessages message) throws IOException {
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment