Apply feedback

Co-authored-by: Francisco Javier Tirado Sarti <65240126+fjtirado@users.noreply.github.com>

Author: gabriel-farache

jbpm/process-serialization-protobuf/src/main/java/org/jbpm/flow/serialization/impl/ProtobufProcessInstanceReader.java

@@ -177,9 +177,8 @@ private RuleFlowProcessInstance buildWorkflow(KogitoProcessInstanceProtobuf.Proc
 
         if (processInstanceProtobuf.getHeadersList() != null) {
             processInstance.setHeaders(processInstanceProtobuf.getHeadersList().stream().collect(Collectors.toMap(HeaderEntry::getKey, HeaderEntry::getValueList)));
-            processInstance.getHeaders().forEach((key, values) -> {
-                LOGGER.info("Header {} restored for process instance {}", key, processInstance.getId());
-            });
+                LOGGER.debug("Headers {} restored for process instance {}", processInstance.getHeaders().keySet(), processInstance.getId()));
+           }
         }
 
         WorkflowContext workflowContext = processInstanceProtobuf.getContext();

jbpm/process-serialization-protobuf/src/main/java/org/jbpm/flow/serialization/impl/ProtobufProcessInstanceWriter.java

@@ -143,8 +143,19 @@ public void writeProcessInstance(WorkflowProcessInstanceImpl workFlow, OutputStr
 
         HeadersPersistentConfig headersConfig = context.get(MARSHALLER_HEADERS_CONFIG);
         if (workFlow.getHeaders() != null && headersConfig != null && headersConfig.enabled()) {
-            Stream<Entry<String, List<String>>> headersStream = getHeadersStream(workFlow, headersConfig);
-            instance.addAllHeaders(headersStream.map(e -> HeaderEntry.newBuilder().setKey(e.getKey()).addAllValue(e.getValue()).build()).collect(Collectors.toList()));
+
+        if (LOGGER.isDebugEnabled()) {
+                LOGGER.debug("Headers {} are associated to process instance {}", workFlow.getHeaders().keySet(), workFlow.getId());
+            }
+            Stream<Entry<String, List<String>>> stream = workFlow.getHeaders().entrySet().stream();
+            if (headersConfig.excluded() != null && !headersConfig.excluded().isEmpty()) {
+                stream = stream.filter(e -> !headersConfig.excluded().contains(e.getKey()));
+            }
+            instance.addAllHeaders(stream.map(e -> HeaderEntry.newBuilder().setKey(e.getKey()).addAllValue(e.getValue()).build()).collect(Collectors.toList()));
+            if (LOGGER.isDebugEnabled()) {
+                LOGGER.debug("Headers {} are stored for process instance {}", instance.getHeadersList().stream().map(HeaderEntry::getKey).collect(Collectors.joining()), workFlow.getId());
+            }
+            
         }
 
         instance.addAllSwimlaneContext(buildSwimlaneContexts((SwimlaneContextInstance) workFlow.getContextInstance(SwimlaneContext.SWIMLANE_SCOPE)));