From 1706275bec82d24b52f858b72d4d4c35a862d070 Mon Sep 17 00:00:00 2001 From: kjaniak Date: Thu, 16 May 2019 16:53:14 +0200 Subject: Write unit tests for MR Subscriber Change-Id: I9ce78cc74898ded8ba6b01513cca9463cb78c345 Issue-ID: DCAEGEN2-1422 Signed-off-by: kjaniak --- .../dmaap/client/impl/MessageRouterSubscriberImpl.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) (limited to 'rest-services/dmaap-client/src/main/java/org/onap') diff --git a/rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/MessageRouterSubscriberImpl.java b/rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/MessageRouterSubscriberImpl.java index 2f49ddf5..2f2e4214 100644 --- a/rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/MessageRouterSubscriberImpl.java +++ b/rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/MessageRouterSubscriberImpl.java @@ -60,6 +60,14 @@ public class MessageRouterSubscriberImpl implements MessageRouterSubscriber { } + private @NotNull HttpRequest buildGetHttpRequest(MessageRouterSubscribeRequest request) { + return ImmutableHttpRequest.builder() + .method(HttpMethod.GET) + .url(buildSubscribeUrl(request)) + .diagnosticContext(request.diagnosticContext().withNewInvocationId()) + .build(); + } + private @NotNull MessageRouterSubscribeResponse buildGetResponse(HttpResponse httpResponse) { final ImmutableMessageRouterSubscribeResponse.Builder builder = ImmutableMessageRouterSubscribeResponse.builder(); @@ -69,14 +77,6 @@ public class MessageRouterSubscriberImpl implements MessageRouterSubscriber { } - private @NotNull HttpRequest buildGetHttpRequest(MessageRouterSubscribeRequest request) { - return ImmutableHttpRequest.builder() - .method(HttpMethod.GET) - .url(buildSubscribeUrl(request)) - .diagnosticContext(request.diagnosticContext().withNewInvocationId()) - .build(); - } - private String buildSubscribeUrl(MessageRouterSubscribeRequest request) { return String.format("%s/%s/%s", request.sourceDefinition().topicUrl(), request.consumerGroup(), request.consumerId()); -- cgit 1.2.3-korg