Skip to content

Commit da68f7a

Browse files
Format files
Signed-off-by: gabriel-farache <gfarache@redhat.com>
1 parent 854f3fe commit da68f7a

File tree

2 files changed

+6
-5
lines changed

2 files changed

+6
-5
lines changed

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -181,8 +181,9 @@ private RuleFlowProcessInstance buildWorkflow(KogitoProcessInstanceProtobuf.Proc
181181
}
182182
}
183183

184-
WorkflowContext workflowContext = processInstanceProtobuf.getContext();
185-
buildWorkflowContext(processInstance, workflowContext);
184+
WorkflowContext workflowContext = processInstanceProtobuf.getContext();
185+
186+
buildWorkflowContext(processInstance, workflowContext);
186187

187188
KogitoProcessRuntime runtime = ((AbstractProcess<?>) context.get(MarshallerContextName.MARSHALLER_PROCESS)).getProcessRuntime();
188189
Arrays.stream(listeners).forEach(e -> e.afterUnmarshallProcess(runtime, processInstance));

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -144,7 +144,7 @@ public void writeProcessInstance(WorkflowProcessInstanceImpl workFlow, OutputStr
144144
HeadersPersistentConfig headersConfig = context.get(MARSHALLER_HEADERS_CONFIG);
145145
if (workFlow.getHeaders() != null && headersConfig != null && headersConfig.enabled()) {
146146

147-
if (LOGGER.isDebugEnabled()) {
147+
if (LOGGER.isDebugEnabled()) {
148148
LOGGER.debug("Headers {} are associated to process instance {}", workFlow.getHeaders().keySet(), workFlow.getId());
149149
}
150150
Stream<Entry<String, List<String>>> stream = workFlow.getHeaders().entrySet().stream();
@@ -155,7 +155,7 @@ public void writeProcessInstance(WorkflowProcessInstanceImpl workFlow, OutputStr
155155
if (LOGGER.isDebugEnabled()) {
156156
LOGGER.debug("Headers {} are stored for process instance {}", instance.getHeadersList().stream().map(HeaderEntry::getKey).collect(Collectors.joining()), workFlow.getId());
157157
}
158-
158+
159159
}
160160

161161
instance.addAllSwimlaneContext(buildSwimlaneContexts((SwimlaneContextInstance) workFlow.getContextInstance(SwimlaneContext.SWIMLANE_SCOPE)));
@@ -182,7 +182,7 @@ private Stream<Entry<String, List<String>>> getHeadersStream(WorkflowProcessInst
182182
}
183183
LOGGER.info("Adding header {} from process instance {} for persistence", e.getKey(), workFlow.getId());
184184
return true;
185-
});
185+
});
186186
}
187187
return stream;
188188
}

0 commit comments

Comments
 (0)