Skip to content

Commit 2692654

Browse files
feat(result): add userId header in result message (#52)
1 parent 7390ab1 commit 2692654

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

src/main/java/org/gridsuite/voltageinit/server/service/NotificationService.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,11 +58,12 @@ public void sendCancelMessage(Message<String> message) {
5858
}
5959

6060
@PostCompletion
61-
public void sendResultMessage(UUID resultUuid, String receiver) {
61+
public void sendResultMessage(UUID resultUuid, String receiver, String userId) {
6262
Message<String> message = MessageBuilder
6363
.withPayload("")
6464
.setHeader(HEADER_RESULT_UUID, resultUuid.toString())
6565
.setHeader(HEADER_RECEIVER, receiver)
66+
.setHeader(HEADER_USER_ID, userId)
6667
.build();
6768
RESULT_MESSAGE_LOGGER.debug(SENDING_MESSAGE, message);
6869
publisher.send("publishResult-out-0", message);

src/main/java/org/gridsuite/voltageinit/server/service/VoltageInitWorkerService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,7 @@ public Consumer<Message<String>> consumeRun() {
220220
LOGGER.info("Reactive slacks : {}", openReacResult.getReactiveSlacks());
221221
LOGGER.info("Indicators : {}", openReacResult.getIndicators());
222222

223-
notificationService.sendResultMessage(resultContext.getResultUuid(), resultContext.getRunContext().getReceiver());
223+
notificationService.sendResultMessage(resultContext.getResultUuid(), resultContext.getRunContext().getReceiver(), resultContext.getRunContext().getUserId());
224224
LOGGER.info("Voltage initialization complete (resultUuid='{}')", resultContext.getResultUuid());
225225
} else { // result not available : stop computation request
226226
if (cancelComputationRequests.get(resultContext.getResultUuid()) != null) {

0 commit comments

Comments
 (0)