diff options
Diffstat (limited to 'rest-services/dmaap-client')
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 |