summaryrefslogtreecommitdiffstats
path: root/models-interactions/model-simulators
diff options
context:
space:
mode:
Diffstat (limited to 'models-interactions/model-simulators')
-rw-r--r--models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/AppcLcmTopicServer.java1
-rw-r--r--models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/AppcLegacyTopicServer.java1
-rw-r--r--models-interactions/model-simulators/src/main/java/org/onap/policy/simulators/SdnrTopicServer.java1
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);
}