/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2023 Nordix Foundation.
+ * Copyright (C) 2024 OpenInfra Foundation Europe. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import java.util.stream.Collectors;
import lombok.AccessLevel;
import lombok.Getter;
-import lombok.RequiredArgsConstructor;
import org.apache.http.HttpStatus;
-import org.onap.policy.clamp.acm.participant.intermediary.api.AutomationCompositionElementListener;
import org.onap.policy.clamp.acm.participant.intermediary.api.ParticipantIntermediaryApi;
+import org.onap.policy.clamp.acm.participant.intermediary.api.impl.AcElementListenerV1;
import org.onap.policy.clamp.models.acm.concepts.AcElementDeploy;
import org.onap.policy.clamp.models.acm.concepts.AcTypeState;
import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionElementDefinition;
import org.springframework.stereotype.Component;
@Component
-@RequiredArgsConstructor
-public class AutomationCompositionElementHandler implements AutomationCompositionElementListener {
+public class AutomationCompositionElementHandler extends AcElementListenerV1 {
private static final Coder CODER = new StandardCoder();
private static final Logger LOGGER = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
- private final ParticipantIntermediaryApi intermediaryApi;
-
private final AcDmeClient acDmeClient;
// Map of acElement Id and DME services
@Getter(AccessLevel.PACKAGE)
private final Map<UUID, ConfigurationEntity> configRequestMap = new ConcurrentHashMap<>();
+ public AutomationCompositionElementHandler(ParticipantIntermediaryApi intermediaryApi, AcDmeClient acDmeClient) {
+ super(intermediaryApi);
+ this.acDmeClient = acDmeClient;
+ }
+
@Override
public void undeploy(UUID automationCompositionId, UUID automationCompositionElementId) throws DmeException {
var configurationEntity = configRequestMap.get(automationCompositionElementId);
participantId: 101c62b3-8918-41b9-a747-d21eb79c6c08
clampAutomationCompositionTopics:
topicSources:
- - topic: POLICY-ACRUNTIME-PARTICIPANT
+ - topic: policy-acruntime-participant
servers:
- - ${topicServer:localhost}
- topicCommInfrastructure: dmaap
+ - ${topicServer:kafka.default.svc.cluster.local:9092}
+ topicCommInfrastructure: NOOP
fetchTimeout: 15000
topicSinks:
- - topic: POLICY-ACRUNTIME-PARTICIPANT
+ - topic: policy-acruntime-participant
servers:
- - ${topicServer:localhost}
- topicCommInfrastructure: dmaap
+ - ${topicServer:kafka.default.svc.cluster.local:9092}
+ topicCommInfrastructure: NOOP
participantSupportedElementTypes:
-
typeName: org.onap.policy.clamp.acm.DMEAutomationCompositionElement
<openapi.maven.version>7.3.0</openapi.maven.version>
<docker-maven-plugin>0.43.4</docker-maven-plugin>
<jacoco-maven-plugin.version>0.8.11</jacoco-maven-plugin.version>
- <onap.acm.models.version>7.1.0</onap.acm.models.version>
+ <onap.acm.models.version>7.1.1</onap.acm.models.version>
<openapi.jackson.databind.nullable.version>0.2.6</openapi.jackson.databind.nullable.version>
</properties>
<build>
<openapi.maven.version>7.3.0</openapi.maven.version>
<docker-maven-plugin>0.43.4</docker-maven-plugin>
<jacoco-maven-plugin.version>0.8.11</jacoco-maven-plugin.version>
- <onap.acm.models.version>7.1.0</onap.acm.models.version>
+ <onap.acm.models.version>7.1.1</onap.acm.models.version>
<openapi.jackson.databind.nullable.version>0.2.6</openapi.jackson.databind.nullable.version>
<spring.statemachine.version>4.0.0</spring.statemachine.version>
<spring.context.version>6.1.3</spring.context.version>