Honor the Retry-After HTTP header in case of 413 status code.

Issue-ID: DCAEGEN2-1483
Signed-off-by: tkogut <tomasz.kogut@nokia.com>
Change-Id: I429474d4a0565f5aa9bd542daa0db814c5504ef6

2 files changed, 7 insertions, 0 deletions

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