summaryrefslogtreecommitdiffstats
path: root/participant/participant-impl/participant-impl-acelement
diff options
context:
space:
mode:
authorFrancescoFioraEst <francesco.fiora@est.tech>2022-09-05 13:17:59 +0100
committerFrancescoFioraEst <francesco.fiora@est.tech>2022-09-12 09:49:29 +0100
commit18a13eaef5fc51556b0985c61e271dfc5a3a4a29 (patch)
tree48ee418f7734afca69c3715e0b03670dba4a62c7 /participant/participant-impl/participant-impl-acelement
parent80fe65ed336eab08e9bf071a08845aef4a802654 (diff)
Fix log of Element container is not visible at Standard Output
Issue-ID: POLICY-4351 Change-Id: I5f06c7158654fc14c2549772f8416eb1fc5bb07b Signed-off-by: FrancescoFioraEst <francesco.fiora@est.tech>
Diffstat (limited to 'participant/participant-impl/participant-impl-acelement')
-rw-r--r--participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/ConfigService.java1
-rw-r--r--participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/SinkService.java10
2 files changed, 10 insertions, 1 deletions
diff --git a/participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/ConfigService.java b/participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/ConfigService.java
index 78ddad681..ff07cef53 100644
--- a/participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/ConfigService.java
+++ b/participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/ConfigService.java
@@ -28,7 +28,6 @@ import org.onap.policy.clamp.acm.element.handler.MessageActivator;
import org.onap.policy.clamp.acm.element.handler.MessageHandler;
import org.onap.policy.clamp.acm.element.main.parameters.ElementTopicParameters;
import org.onap.policy.clamp.common.acm.exception.AutomationCompositionRuntimeException;
-import org.onap.policy.clamp.models.acm.messages.dmaap.element.ElementMessage;
import org.onap.policy.clamp.models.acm.messages.rest.element.ElementConfig;
import org.onap.policy.common.endpoints.parameters.TopicParameterGroup;
import org.slf4j.Logger;
diff --git a/participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/SinkService.java b/participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/SinkService.java
index 61c1c7812..6de8255ba 100644
--- a/participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/SinkService.java
+++ b/participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/SinkService.java
@@ -20,7 +20,10 @@
package org.onap.policy.clamp.acm.element.service;
+import org.onap.policy.clamp.models.acm.messages.dmaap.element.ElementMessage;
import org.onap.policy.clamp.models.acm.messages.rest.element.ElementType;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
/**
@@ -29,6 +32,13 @@ import org.springframework.stereotype.Service;
@Service
public class SinkService extends AbstractElementService {
+ private static final Logger LOGGER = LoggerFactory.getLogger(SinkService.class);
+
+ @Override
+ public void handleMessage(ElementMessage message) {
+ LOGGER.info("Cycle completed in sink service with the full message: " + message);
+ }
+
@Override
public ElementType getType() {
return ElementType.SINK;