feat: provide old native header id

Onlineberatung · Jun 22, 2021 · e765f77 · e765f77
1 parent 09a62d4
commit e765f77
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/de/caritas/cob/liveservice/websocket/service/LiveEventSendService.java b/src/main/java/de/caritas/cob/liveservice/websocket/service/LiveEventSendService.java
@@ -30,6 +30,7 @@
 public class LiveEventSendService {
 
   private static final Logger LOGGER = LoggerFactory.getLogger(LiveEventSendService.class);
+  private static final String NATIVE_HEADER_ID = "id";
 
   private final @NonNull SimpMessagingTemplate simpMessagingTemplate;
   private final @NonNull LiveEventMessageQueue liveEventMessageQueue;
@@ -71,8 +72,9 @@ public void sendIdentifiedMessage(IdentifiedMessage identifiedMessage) {
     var headerAccessor = StompHeaderAccessor.create(StompCommand.MESSAGE);
     headerAccessor
         .setSessionId(identifiedMessage.getWebsocketUserSession().getWebsocketSessionId());
-    headerAccessor.setLeaveMutable(true);
     headerAccessor.setMessageId(identifiedMessage.getMessageId());
+    headerAccessor.addNativeHeader(NATIVE_HEADER_ID, identifiedMessage.getMessageId());
+    headerAccessor.setLeaveMutable(true);
     this.simpMessagingTemplate
         .convertAndSendToUser(identifiedMessage.getWebsocketUserSession().getWebsocketSessionId(),
             EVENTS.getSubscriptionEndpoint(), identifiedMessage.getLiveEventMessage(),