From 573c53f8f8dbd220f34b718399ddd3bd1a3121a9 Mon Sep 17 00:00:00 2001 From: tkogut Date: Wed, 24 Feb 2021 12:04:53 +0100 Subject: Honor the Retry-After HTTP header in case of 413 status code. Issue-ID: DCAEGEN2-1483 Signed-off-by: tkogut Change-Id: I429474d4a0565f5aa9bd542daa0db814c5504ef6 --- .../services/dmaap/client/impl/MessageRouterPublisherImplTest.java | 2 ++ .../services/dmaap/client/impl/MessageRouterSubscriberImplTest.java | 5 +++++ 2 files changed, 7 insertions(+) (limited to 'rest-services/dmaap-client/src') diff --git a/rest-services/dmaap-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/MessageRouterPublisherImplTest.java b/rest-services/dmaap-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/MessageRouterPublisherImplTest.java index 2fde441d..6c6ded16 100644 --- a/rest-services/dmaap-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/MessageRouterPublisherImplTest.java +++ b/rest-services/dmaap-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/MessageRouterPublisherImplTest.java @@ -28,6 +28,7 @@ import com.google.gson.JsonPrimitive; import io.netty.buffer.ByteBufAllocator; import io.netty.handler.codec.http.HttpHeaderValues; import io.netty.handler.timeout.ReadTimeoutException; +import io.vavr.collection.HashMultimap; import io.vavr.collection.List; import org.junit.jupiter.api.Test; import org.mockito.ArgumentCaptor; @@ -545,6 +546,7 @@ class MessageRouterPublisherImplTest { .url(TOPIC_URL) .statusReason(statusReason) .rawBody("[]".getBytes()) + .headers(HashMultimap.withSeq().empty()) .build(); } diff --git a/rest-services/dmaap-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/MessageRouterSubscriberImplTest.java b/rest-services/dmaap-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/MessageRouterSubscriberImplTest.java index 74b21ad6..006965c2 100644 --- a/rest-services/dmaap-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/MessageRouterSubscriberImplTest.java +++ b/rest-services/dmaap-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/MessageRouterSubscriberImplTest.java @@ -30,6 +30,7 @@ import static org.mockito.Mockito.verify; import com.google.gson.JsonSyntaxException; import io.netty.handler.timeout.ReadTimeoutException; +import io.vavr.collection.HashMultimap; import org.junit.jupiter.api.Test; import org.mockito.ArgumentCaptor; import org.onap.dcaegen2.services.sdk.model.streams.dmaap.ImmutableMessageRouterSource; @@ -72,24 +73,28 @@ class MessageRouterSubscriberImplTest { .statusReason("OK") .url(sourceDefinition.topicUrl()) .rawBody("[]".getBytes()) + .headers(HashMultimap.withSeq().empty()) .build(); private final HttpResponse retryableHttpResponse = ImmutableHttpResponse.builder() .statusCode(500) .statusReason("Something braked") .url(sourceDefinition.topicUrl()) .rawBody("[]".getBytes()) + .headers(HashMultimap.withSeq().empty()) .build(); private final HttpResponse httpResponseWithWrongStatusCode = ImmutableHttpResponse.builder() .statusCode(301) .statusReason("Something braked") .url(sourceDefinition.topicUrl()) .rawBody("[]".getBytes()) + .headers(HashMultimap.withSeq().empty()) .build(); private final HttpResponse httpResponseWithIncorrectJson = ImmutableHttpResponse.builder() .statusCode(200) .statusReason("OK") .url(sourceDefinition.topicUrl()) .rawBody("{}".getBytes()) + .headers(HashMultimap.withSeq().empty()) .build(); @Test -- cgit 1.2.3-korg