Skip to content

Commit d71408e

Browse files
committed
Support One Bus Short Circuit
Signed-off-by: Thang PHAM <[email protected]>
1 parent 9cf49b7 commit d71408e

File tree

1 file changed

+10
-5
lines changed

1 file changed

+10
-5
lines changed

src/main/java/org/gridsuite/computation/service/AbstractWorkerService.java

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -273,13 +273,18 @@ protected void sendResultMessage(AbstractResultContext<C> resultContext, R ignor
273273
}
274274

275275
private void sendDebugMessage(AbstractResultContext<C> resultContext, @Nullable String messageError) {
276-
Map<String, Object> resultHeaders = new HashMap<>();
277-
278-
// --- attach debug to result headers --- //
279-
resultHeaders.put(HEADER_ERROR_MESSAGE, messageError);
276+
Map<String, Object> debugHeaders = getDebugHeaders(resultContext, messageError);
280277

281278
notificationService.sendDebugMessage(resultContext.getResultUuid(), resultContext.getRunContext().getReceiver(),
282-
resultContext.getRunContext().getUserId(), resultHeaders);
279+
resultContext.getRunContext().getUserId(), debugHeaders);
280+
}
281+
282+
protected Map<String, Object> getDebugHeaders(AbstractResultContext<C> resultContext, String messageError) {
283+
Map<String, Object> headers = new HashMap<>();
284+
285+
// --- attach an error message to result headers --- //
286+
headers.put(HEADER_ERROR_MESSAGE, messageError);
287+
return headers;
283288
}
284289

285290
/**

0 commit comments

Comments
 (0)