Skip to content

Commit

Permalink
chore: test socker client connection
Browse files Browse the repository at this point in the history
  • Loading branch information
Markus Eberl committed Jun 17, 2021
1 parent be2be99 commit 1c3e627
Showing 1 changed file with 4 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,8 @@
import de.caritas.cob.liveservice.websocket.registry.LiveEventMessageQueue;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.messaging.Message;
import org.springframework.messaging.simp.stomp.StompCommand;
import org.springframework.stereotype.Component;
Expand All @@ -16,6 +18,7 @@
@RequiredArgsConstructor
public class StompAcknowledgeHandler implements StompHandler {

private static final Logger LOGGER = LoggerFactory.getLogger(StompAcknowledgeHandler.class);
private static final String MESSAGE_ID = "message-id";

private final @NonNull LiveEventMessageQueue liveEventMessageQueue;
Expand All @@ -28,6 +31,7 @@ public class StompAcknowledgeHandler implements StompHandler {
@Override
public void handle(Message<?> inboundMessage) {
if (nonNull(inboundMessage)) {
LOGGER.info("Inbound Message = {}", inboundMessage);
var messageId = extractFirstNativeHeader(inboundMessage, MESSAGE_ID);
this.liveEventMessageQueue.removeIdentifiedMessageWithId(messageId);
}
Expand Down

0 comments on commit 1c3e627

Please sign in to comment.