diff options
| author |   rameshiyer27 <ramesh.murugan.iyer@est.tech> | 2024-01-29 09:23:58 +0000 |
|---|---|---|
| committer | Ramesh Murugan Iyer <ramesh.murugan.iyer@est.tech> | 2024-02-08 14:29:41 +0000 |
| commit | 49f07db935d114b72a44e446867b16262dd552aa (patch) | |
| tree | f6867985541acb76f1e5279ed4104c86dc7adffb /models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/AppcLcmTopicServer.java | |
| parent | 71be21fd5b9b52c613bb855f00a79a51e81906dd (diff) | |
Remove dmaap from models
Issue-ID: POLICY-4402
Change-Id: Icead1601984f463e557b969f2792f0f0aa05f060
Signed-off-by: rameshiyer27 <ramesh.murugan.iyer@est.tech>
Diffstat (limited to 'models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/AppcLcmTopicServer.java')
| -rw-r--r-- | models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/AppcLcmTopicServer.java | 9 |
1 files changed, 5 insertions, 4 deletions
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 a8ec6e5e9..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 @@ -3,6 +3,7 @@ * ONAP * ================================================================================ * 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<AppcLcmDmaapWrapper> { +public class AppcLcmTopicServer extends TopicServer<AppcLcmMessageWrapper> { 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 |