Skip to content
Snippets Groups Projects
Commit 005fee69 authored by Zhibin Mai's avatar Zhibin Mai
Browse files
parents bc1642bb 55938310
No related branches found
No related tags found
1 merge request!465Index extended properties defined in property configurations
......@@ -23,7 +23,6 @@ import lombok.extern.slf4j.Slf4j;
import org.opengroup.osdu.core.auth.TokenProvider;
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.http.RequestStatus;
import org.opengroup.osdu.core.gcp.oqm.model.OqmAckReplier;
import org.opengroup.osdu.core.gcp.oqm.model.OqmMessage;
import org.opengroup.osdu.core.gcp.oqm.model.OqmMessageReceiver;
......@@ -57,7 +56,7 @@ public abstract class IndexerOqmMessageReceiver implements OqmMessageReceiver {
oqmAckReplier.ack();
} catch (AppException appException) {
int statusCode = appException.getError().getCode();
if (statusCode > 199 && statusCode < 300 && statusCode != RequestStatus.INVALID_RECORD) {
if (statusCode > 199 && statusCode < 300) {
skipMessage(oqmMessage, dpsHeaders, oqmAckReplier, appException);
} else {
rescheduleMessage(oqmMessage, dpsHeaders, oqmAckReplier, getException(appException));
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment