Skip to content
Snippets Groups Projects
Commit 55938310 authored by Riabokon Stanislav(EPAM)[GCP]'s avatar Riabokon Stanislav(EPAM)[GCP]
Browse files

Merge branch 'gc-fix-rescheduling' into 'master'

remove reprocessing in case storage respond with no valid records

See merge request !551
parents 52b2a553 edd8ec7b
No related branches found
No related tags found
1 merge request!551remove reprocessing in case storage respond with no valid records
Pipeline #188289 failed
...@@ -23,7 +23,6 @@ import lombok.extern.slf4j.Slf4j; ...@@ -23,7 +23,6 @@ import lombok.extern.slf4j.Slf4j;
import org.opengroup.osdu.core.auth.TokenProvider; import org.opengroup.osdu.core.auth.TokenProvider;
import org.opengroup.osdu.core.common.model.http.AppException; 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.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.OqmAckReplier;
import org.opengroup.osdu.core.gcp.oqm.model.OqmMessage; import org.opengroup.osdu.core.gcp.oqm.model.OqmMessage;
import org.opengroup.osdu.core.gcp.oqm.model.OqmMessageReceiver; import org.opengroup.osdu.core.gcp.oqm.model.OqmMessageReceiver;
...@@ -57,7 +56,7 @@ public abstract class IndexerOqmMessageReceiver implements OqmMessageReceiver { ...@@ -57,7 +56,7 @@ public abstract class IndexerOqmMessageReceiver implements OqmMessageReceiver {
oqmAckReplier.ack(); oqmAckReplier.ack();
} catch (AppException appException) { } catch (AppException appException) {
int statusCode = appException.getError().getCode(); int statusCode = appException.getError().getCode();
if (statusCode > 199 && statusCode < 300 && statusCode != RequestStatus.INVALID_RECORD) { if (statusCode > 199 && statusCode < 300) {
skipMessage(oqmMessage, dpsHeaders, oqmAckReplier, appException); skipMessage(oqmMessage, dpsHeaders, oqmAckReplier, appException);
} else { } else {
rescheduleMessage(oqmMessage, dpsHeaders, oqmAckReplier, getException(appException)); 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