"controllerName": "usecases",
"sourceTopics": [
{
- "topicName": "DCAE_TOPIC",
+ "topicName": "dcae_topic",
"events": [
{
"eventClass": "org.onap.policy.controlloop.CanonicalOnset",
]
},
{
- "topicName": "APPC-CL",
+ "topicName": "appc-cl",
"events": [
{
"eventClass": "org.onap.policy.appc.Response",
]
},
{
- "topicName": "APPC-LCM-WRITE",
+ "topicName": "appc-lcm-write",
"events": [
{
"eventClass": "org.onap.policy.appclcm.AppcLcmMessageWrapper",
]
},
{
- "topicName": "SDNR-CL-RSP",
+ "topicName": "sdnr-cl-rsp",
"events": [
{
"eventClass": "org.onap.policy.sdnr.PciResponseWrapper",
],
"sinkTopics": [
{
- "topicName": "APPC-CL",
+ "topicName": "appc-cl",
"events": [
{
"eventClass": "org.onap.policy.appc.Request",
]
},
{
- "topicName": "APPC-LCM-READ",
+ "topicName": "appc-lcm-read",
"events": [
{
"eventClass": "org.onap.policy.appclcm.AppcLcmMessageWrapper",
]
},
{
- "topicName": "POLICY-CL-MGT",
+ "topicName": "policy-cl-mgt",
"events": [
{
"eventClass": "org.onap.policy.controlloop.VirtualControlLoopNotification",
]
},
{
- "topicName": "DCAE_CL_RSP",
+ "topicName": "dcae_cl_rsp",
"events": [
{
"eventClass": "org.onap.policy.controlloop.ControlLoopResponse",
properties:
controllerName: usecases
sourceTopics:
- - topicName: DCAE_TOPIC
+ - topicName: dcae_topic
events:
- eventClass: org.onap.policy.controlloop.CanonicalOnset
eventFilter: '[?($.closedLoopEventStatus == ''ONSET'')]'
customSerialization:
customSerializerClass: org.onap.policy.controlloop.util.Serialization
jsonParser: gson
- - topicName: APPC-CL
+ - topicName: appc-cl
events:
- eventClass: org.onap.policy.appc.Response
eventFilter: '[?($.CommonHeader && $.Status)]'
customSerialization:
customSerializerClass: org.onap.policy.appc.util.Serialization
jsonParser: gsonPretty
- - topicName: APPC-LCM-WRITE
+ - topicName: appc-lcm-write
events:
- eventClass: org.onap.policy.appclcm.AppcLcmMessageWrapper
eventFilter: '[?($.type == ''response'')]'
customSerialization:
customSerializerClass: org.onap.policy.appclcm.util.Serialization
jsonParser: gson
- - topicName: SDNR-CL-RSP
+ - topicName: sdnr-cl-rsp
events:
- eventClass: org.onap.policy.sdnr.PciResponseWrapper
eventFilter: '[?($.type == ''response'')]'
customSerializerClass: org.onap.policy.sdnr.util.Serialization
jsonParser: gson
sinkTopics:
- - topicName: APPC-CL
+ - topicName: appc-cl
events:
- eventClass: org.onap.policy.appc.Request
customSerialization:
customSerializerClass: org.onap.policy.appc.util.Serialization
jsonParser: gsonPretty
- - topicName: APPC-LCM-READ
+ - topicName: appc-lcm-read
events:
- eventClass: org.onap.policy.appclcm.AppcLcmMessageWrapper
customSerialization:
customSerializerClass: org.onap.policy.appclcm.util.Serialization
jsonParser: gson
- - topicName: POLICY-CL-MGT
+ - topicName: policy-cl-mgt
events:
- eventClass: org.onap.policy.controlloop.VirtualControlLoopNotification
customSerialization:
customSerializerClass: org.onap.policy.controlloop.util.Serialization
jsonParser: gsonPretty
- - topicName: DCAE_CL_RSP
+ - topicName: dcae_cl_rsp
events:
- eventClass: org.onap.policy.controlloop.ControlLoopResponse
customSerialization:
* @param operation operation to run
*/
protected void verifyOperation(AppcOperation operation)
- throws InterruptedException, ExecutionException, TimeoutException {
+ throws InterruptedException, ExecutionException {
CompletableFuture<OperationOutcome> future2 = operation.start();
executor.runAll(100);
* @param yamlConfigFile YAML configuration file name
* @return the configuration that was read from the file
* @throws AssertionError if an error occurs
- * @throws CoderException if an error occurs
*/
private MyConfig readConfig(String yamlConfigFile) {
try {
import org.onap.policy.controlloop.actorserviceprovider.topic.BidirectionalTopicManager;
import org.onap.policy.controlloop.actorserviceprovider.topic.Forwarder;
import org.onap.policy.simulators.TopicServer;
-import org.onap.policy.simulators.Util;
/**
* Superclass for various BidirectionalTopicOperation tests.
<artifactId>assertj-core</artifactId>
<scope>test</scope>
</dependency>
+ <dependency>
+ <groupId>io.opentelemetry</groupId>
+ <artifactId>opentelemetry-context</artifactId>
+ <scope>runtime</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.kafka</groupId>
+ <artifactId>kafka-clients</artifactId>
+ <scope>runtime</scope>
+ </dependency>
</dependencies>
</project>