diff options
Diffstat (limited to 'models-interactions/model-simulators')
3 files changed, 3 insertions, 0 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 6b2eabe8d..3b0d8cd72 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 @@ -30,6 +30,7 @@ import org.onap.policy.common.utils.resources.ResourceUtils; * APPC-LCM topic server. */ public class AppcLcmTopicServer extends TopicServer<AppcLcmDmaapWrapper> { + public AppcLcmTopicServer(TopicSink sink, TopicSource source) { super(sink, source, new StandardCoder(), AppcLcmDmaapWrapper.class); } diff --git a/models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/AppcLegacyTopicServer.java b/models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/AppcLegacyTopicServer.java index 0c259783d..c3f0435c9 100644 --- a/models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/AppcLegacyTopicServer.java +++ b/models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/AppcLegacyTopicServer.java @@ -30,6 +30,7 @@ import org.onap.policy.common.utils.resources.ResourceUtils; * Legacy APPC topic server. */ public class AppcLegacyTopicServer extends TopicServer<Request> { + public AppcLegacyTopicServer(TopicSink sink, TopicSource source) { super(sink, source, new StandardCoderInstantAsMillis(), Request.class); } diff --git a/models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/SdnrTopicServer.java b/models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/SdnrTopicServer.java index 043a2c523..9aad4d4b3 100644 --- a/models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/SdnrTopicServer.java +++ b/models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/SdnrTopicServer.java @@ -30,6 +30,7 @@ import org.onap.policy.sdnr.PciMessage; * SDNR topic server. */ public class SdnrTopicServer extends TopicServer<PciMessage> { + public SdnrTopicServer(TopicSink sink, TopicSource source) { super(sink, source, new StandardCoder(), PciMessage.class); } |