diff options
| author |   FrancescoFioraEst <francesco.fiora@est.tech> | 2022-09-05 13:17:59 +0100 |
|---|---|---|
| committer | FrancescoFioraEst <francesco.fiora@est.tech> | 2022-09-12 09:49:29 +0100 |
| commit | 18a13eaef5fc51556b0985c61e271dfc5a3a4a29 (patch) | |
| tree | 48ee418f7734afca69c3715e0b03670dba4a62c7 /participant/participant-impl/participant-impl-acelement | |
| parent | 80fe65ed336eab08e9bf071a08845aef4a802654 (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')
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; |