aboutsummaryrefslogtreecommitdiffstats
path: root/rest-services/dmaap-client/src/main/java
diff options
context:
space:
mode:
authorkjaniak <kornel.janiak@nokia.com>2019-05-16 16:53:14 +0200
committerkjaniak <kornel.janiak@nokia.com>2019-05-16 16:54:46 +0200
commit1706275bec82d24b52f858b72d4d4c35a862d070 (patch)
treef94b6500fc6e768030caba60cf57916911b60648 /rest-services/dmaap-client/src/main/java
parente8beff45a8cde47485d44b692ef579ce2b755f69 (diff)
Write unit tests for MR Subscriber
Change-Id: I9ce78cc74898ded8ba6b01513cca9463cb78c345 Issue-ID: DCAEGEN2-1422 Signed-off-by: kjaniak <kornel.janiak@nokia.com>
Diffstat (limited to 'rest-services/dmaap-client/src/main/java')
-rw-r--r--rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/MessageRouterSubscriberImpl.java16
1 files changed, 8 insertions, 8 deletions
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());