X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=models-interactions%2Fmodel-simulators%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fpolicy%2Fsimulators%2FAppcLcmTopicServer.java;h=62e1acc9c75eb8b9172d4c2f688b57d13960b9a9;hb=HEAD;hp=3b0d8cd7267b98e683fb2d8f78171536355d5349;hpb=61a84fecc1eae8640fec2860f4b50102ed0baa64;p=policy%2Fmodels.git diff --git a/models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/AppcLcmTopicServer.java b/models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/AppcLcmTopicServer.java index 3b0d8cd72..62e1acc9c 100644 --- a/models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/AppcLcmTopicServer.java +++ b/models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/AppcLcmTopicServer.java @@ -2,7 +2,8 @@ * ============LICENSE_START======================================================= * ONAP * ================================================================================ - * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved. + * Copyright (C) 2020-2021 AT&T Intellectual Property. All rights reserved. + * Modifications Copyright (C) 2024 Nordix Foundation. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -20,7 +21,7 @@ package org.onap.policy.simulators; -import org.onap.policy.appclcm.AppcLcmDmaapWrapper; +import org.onap.policy.appclcm.AppcLcmMessageWrapper; import org.onap.policy.common.endpoints.event.comm.TopicSink; import org.onap.policy.common.endpoints.event.comm.TopicSource; import org.onap.policy.common.utils.coder.StandardCoder; @@ -29,14 +30,14 @@ import org.onap.policy.common.utils.resources.ResourceUtils; /** * APPC-LCM topic server. */ -public class AppcLcmTopicServer extends TopicServer { +public class AppcLcmTopicServer extends TopicServer { public AppcLcmTopicServer(TopicSink sink, TopicSource source) { - super(sink, source, new StandardCoder(), AppcLcmDmaapWrapper.class); + super(sink, source, new StandardCoder(), AppcLcmMessageWrapper.class); } @Override - protected String process(AppcLcmDmaapWrapper request) { + protected String process(AppcLcmMessageWrapper request) { /* * In case the request and response are on the same topic, this may be invoked * with a request or with a response object. If the "output" is not null, then we @@ -46,7 +47,7 @@ public class AppcLcmTopicServer extends TopicServer { return null; } - String response = ResourceUtils.getResourceAsString("org/onap/policy/simulators/appclcm/appc.lcm.success.json"); + var response = ResourceUtils.getResourceAsString("org/onap/policy/simulators/appclcm/appc.lcm.success.json"); return response.replace("${replaceMe}", request.getBody().getInput().getCommonHeader().getSubRequestId()); } }