Merge "enable merge sdc client part into Distribution release image"

[multicloud/framework.git] / artifactbroker / reception / src / main / java / org / onap / policy / distribution / reception / handling / AbstractReceptionHandler.java

diff --git a/artifactbroker/reception/src/main/java/org/onap/policy/distribution/reception/handling/AbstractReceptionHandler.java b/artifactbroker/reception/src/main/java/org/onap/policy/distribution/reception/handling/AbstractReceptionHandler.java
index 7081dc7..86680c6 100644 (file)
--- a/artifactbroker/reception/src/main/java/org/onap/policy/distribution/reception/handling/AbstractReceptionHandler.java
+++ b/artifactbroker/reception/src/main/java/org/onap/policy/distribution/reception/handling/AbstractReceptionHandler.java
@@ -53,6 +53,9 @@ public abstract class AbstractReceptionHandler implements ReceptionHandler {
         final ReceptionHandlerParameters receptionHandlerParameters = ParameterService.get(parameterGroupName);
         pluginHandler = new PluginHandler(receptionHandlerParameters.getPluginHandlerParameters().getName());
         initializeReception(receptionHandlerParameters.getReceptionHandlerConfigurationName());
+        LOGGER.debug("Policy distribution , parameterGroupName = " + parameterGroupName);
+        LOGGER.debug("Policy distribution , pluginhandler name = " + receptionHandlerParameters.getPluginHandlerParameters().getName());
+        LOGGER.debug("Policy distribution , recetipionhandler name = " + receptionHandlerParameters.getReceptionHandlerConfigurationName());
     }
 
     /**
@@ -74,11 +77,10 @@ public abstract class AbstractReceptionHandler implements ReceptionHandler {
      */
     protected void inputReceived(final PolicyInput policyInput) throws PolicyDecodingException {
 
-        final Collection<IArtifactInfo> policies = new ArrayList<>();
 
         for (final ArtifactForwarder policyForwarder : pluginHandler.getArtifactForwarders()) {
             try {
-                policyForwarder.forward(policies);
+                policyForwarder.forward(policyInput);
             } catch (final ArtifactForwardingException policyForwardingException) {
                 LOGGER.error("Error when forwarding policies to " + policyForwarder, policyForwardingException);
             }